首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Apache Camel + RabbitMQ。未创建终结点

Apache Camel + RabbitMQ。未创建终结点
EN

Stack Overflow用户
提问于 2014-03-17 15:46:16
回答 1查看 1.7K关注 0票数 0

我已经创建了项目,其中只包含rabbitmq的路由设置。

代码语言:javascript
复制
<route>
    <from uri="rabbitmq:localhost/test_out_ex?queue=test_out&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
    <to uri="rabbitmq:localhost/test_in_ex?queue=test_in&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
</route>

我在tomcat上运行它,Camel只创建"from"-endpoint,而不是"to“(我在rabbitMq web界面中查找)。为什么?因为"to“还没有消费者吗?

更多详细信息:

问题是消息没有保存在输出消息队列中。这是正常情况,当应用程序向队列发送消息时,此时还没有让消费者在线,所以它应该保存消息,直到消费者连接。

因此,我定义了简单路由并将其部署到tomcat上,同时我还部署了Jolokia项目来通过Hawtio监控我的camel上下文。Hawtio向我展示了,该路由是创建的,由两个端点组成。然后,我通过RabbitMq web接口将消息发布到'test_out‘。Hawtio告诉我,它到达了'test_in‘队列,但在RabbitMq web界面(或rabbitmqctl)中,'test_in’队列不存在,所以在服务器重启后消息消失了。

EN

回答 1

Stack Overflow用户

发布于 2014-03-19 19:02:45

当从test_out路由到test_in时,我们需要过滤消息头,这可能会造成一些问题。

代码语言:javascript
复制
<route>
    <from uri="rabbitmq:localhost/test_out_ex?queue=test_out&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
    <removeHeader pattern="rabbitmq.*"/>
    <to uri="rabbitmq:localhost/test_in_ex?queue=test_in&amp;autoDelete=false&amp;username=admin&amp;password=admin"/>
</route>
票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/22449086

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档