Apache Camel Route не может найти конечную точку
Я создал маршрут cxf для своего приложения следующим образом:
from("cxfrs:{{url}}?resourceClasses=MyImpl&bindingStyle=SimpleConsumer")
.to("${header.operationName}").end();
from("direct:{{getUser}}")
.bean("userImpl", "getUserByName")
.marshal().json(JsonLibrary.Jackson)
.to("log:foo");
from("direct:{{login}}")
.bean("userImpl", "loginUser")
.marshal().json(JsonLibrary.Jackson)
.to("log:foo");
Если я пытаюсь получить свое имя операции в процессоре, я могу получить его, но если я вызываю этот маршрут, у меня появляется это сообщение:
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/>
<title>Error 500 No consumers available on endpoint: Endpoint[direct://$%7Bheader.operationName%7D]. Exchange[ID-NBSPO049-64311-1498773394077-0-2] while invoking public java.lang.String com.itau.ea4.implementacao.UserImpl.loginUser(java.lang.String,java.lang.String) with params [teste, 1234].</title>
</head>
<body>
<h2>HTTP ERROR 500</h2>
<p>Problem accessing /user/login. Reason:
<pre> No consumers available on endpoint: Endpoint[direct://$%7Bheader.operationName%7D]. Exchange[ID-NBSPO049-64311-1498773394077-0-2] while invoking public java.lang.String com.itau.ea4.implementacao.UserImpl.loginUser(java.lang.String,java.lang.String) with params [teste, 1234].</pre>
</p>
<hr>
<i>
<small>Powered by Jetty://</small>
</i>
<hr/>
</body>
Что не так с моим маршрутом? А почему мой заголовок не может быть распознан?
1 ответ
Решение
Проблема в:
.to("${header.operationName}")
"to (...)" не поддерживает динамические данные, поэтому в вашем случае он фактически пытается отправить в конечную точку "direct:{header.operationName}".
Чтобы использовать динамическое значение из заголовка, вы можете использовать toD (из Camel 2.19) или receientsList с одним получателем (Camel до 2.19)