问题标签 [akka-camel]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
7306 浏览

scala - 找不到端点:测试,请检查您的类路径是否包含所需的 Camel 组件 jar

我正在尝试使用akka-camel并为生产者和消费者创建一个示例示例来发送和接收消息,如下所示:

制片人:

消费者:

但是我在生产者和消费者中都面临如下问题。我错过了什么?

制片人:

java.lang.IllegalArgumentException:必须指定目的地

消费者 :

原因:org.apache.camel.NoSuchEndpointException:找不到端点:测试,请检查您的类路径是否包含所需的 Camel 组件 jar。

0 投票
0 回答
933 浏览

java - Apache Camel 错误响应 JSON - UTF8

我对 Apache Camel Rest 服务有以下配置:

我无权访问 Camel 项目代码。我只能访问 xml 配置文件。

我在请求中发送一个 JSON,如下所示:

我必须收到带有“波浪号”的西班牙语或葡萄牙语文本作为响应的 JSON。但我收到一个带有额外字符的 XML。

我需要接收 JSON 而不是 XML。

JSON 必须是这样的:

我的配置有什么问题或我缺少什么?

我通过 SOAP UI 发送请求,它在 JSON 选项卡中显示此消息:

您尝试查看的内容无法以 JSON 格式查看

谢谢。

0 投票
0 回答
132 浏览

apache-camel - Apache Camel doTry doCatch 没有捕获 akka 骆驼异常

我们将 XML DSL 与 Akka Camel (2.5.13) 一起使用,发现当骆驼指向一个 bean 时,该 bean 以异常回答,它不会被 Camel 捕获。

我们的 Scala 代码:

我们的骆驼路线:

在骆驼日志上:

启动演员 ActorName 时出错:具有相同名称的演员已经在运行 akka.actor.InvalidActorNameException:演员名称 [ActorName] 不是唯一的!在 akka.actor.dungeon.ChildrenContainer$NormalChildrenContainer.reserve(ChildrenContainer.scala:129) 在 akka.actor.dungeon.Children$class.reserveChild(Children.scala:134) 在 akka.actor.ActorCell.reserveChild(ActorCell.scala :431) at akka.actor.dungeon.Children$class.makeChild(Children.scala:27​​2) at akka.actor.dungeon.Children$class.attachChild(Children.scala:48) at akka.actor.ActorCell.attachChild( ActorCell.scala:431) at akka.actor.ActorSystemImpl.actorOf(ActorSystem.scala:734) at com.app.akka.App$.createChannelActor(SwApp.scala:233) at com.app.akka.App$.createActor (SwApp.scala:199) 在 com.app.akka.App$.startChannelByName(SwApp.scala:137) 在 com.app.akka.actors.management。runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) 2018-08-13 10:11 :45,807 错误 org.apache.camel.processor.DefaultErrorHandler (MessageId:ExchangeId 上的 ID-my-pc-1534165894710-0-25:ID-my-pc-1534165894710-0-26)传递失败。交付尝试后耗尽:1 捕获:ChannelException(错误启动演员 ActorName:同名演员已经在运行,Map(MessageExchangeId -> ID-my-pc-1534165894710-0-26,breadcrumbId -> ID-my-pc- 1534165894710-0-26, COMMAND_TYPE -> START_ACTOR, ID_ACTOR -> ActorName)) 运行(ForkJoinWorkerThread.java:107)2018-08-13 10:11:45,807 错误 org.apache.camel.processor.DefaultErrorHandler 传递失败(MessageId:ID-my-pc-1534165894710-0-25 on ExchangeId:ID-我的 PC-1534165894710-0-26)。交付尝试后耗尽:1 捕获:ChannelException(错误启动演员 ActorName:同名演员已经在运行,Map(MessageExchangeId -> ID-my-pc-1534165894710-0-26,breadcrumbId -> ID-my-pc- 1534165894710-0-26, COMMAND_TYPE -> START_ACTOR, ID_ACTOR -> ActorName)) 运行(ForkJoinWorkerThread.java:107)2018-08-13 10:11:45,807 错误 org.apache.camel.processor.DefaultErrorHandler 传递失败(MessageId:ID-my-pc-1534165894710-0-25 on ExchangeId:ID-我的 PC-1534165894710-0-26)。交付尝试后耗尽:1 捕获:ChannelException(错误启动演员 ActorName:同名演员已经在运行,Map(MessageExchangeId -> ID-my-pc-1534165894710-0-26,breadcrumbId -> ID-my-pc- 1534165894710-0-26, COMMAND_TYPE -> START_ACTOR, ID_ACTOR -> ActorName))

如果我使用一个只返回错误的 bean,它工作得很好,例如:

知道是什么原因造成的吗?