我试图使用SpringBoot1.5.2.RELEASE+ Camel (Spring ) 2.19.2来侦听ActiveMQ队列,然后将消息发送到rest端点URL (POST方法)作为它的主体。实现这一目标的最佳途径是什么?我收集了一些信息,并试图把它们联系在一起,但有点困惑。
这里是我为Camel Rest DSL收集的内容,我不太确定下面的camel是通过这个创建这些rest服务,还是它只是一个已经公开的端点,在我的例子中它是一个已经公开的端点。
rest("/basePath")
post("/someEndpoint").to("direct:restEndpoint")使用上述内容是我为ActiveMQ收集到的,但我不太确定它是否正确。
from("activemq:queue:<queue_name>").to("direct:restEndpoint")但是,我不太确定如何侦听ActiveMQ队列中的新消息,或者是骆驼默认总是这样做的吗?此外,我需要将消息作为post体传递到rest端点。我还看到了一些对camel-http 4和camel-http的引用,我完全感到困惑。
如能提供任何协助,将不胜感激。
发布于 2017-08-22 15:12:32
当开始使用Camel时,有些混淆是常见的,但您的最终解决方案如下所示:
from("activemq:queue:my-route")
.process(/* change the in/out messages if you need to */)
.to("http4://your-endpoint.com");不要试图简单地复制/粘贴这段代码,直到它生效。我的骆驼经验法则是:总是阅读组件文档,并尝试在您的软件中使用它。就你而言,我建议:
你的第一条路线会花一些时间做一些简单的事情,但你会很快地开始流动。
https://stackoverflow.com/questions/45810640
复制相似问题