我希望有人能够提供一些关于此问题的帮助。
我正在使用Camel RabbitMQ进行测试,尝试向队列发送消息,并在RabbitMQ界面中显示并读取它。
但我无法使其正常工作。
我认为起作用的是,在RabbitMQ管理界面的Exchange选项卡中创建了一个新的Exchange。 在我的Java代码中,我将消息发送到该Exchange。当代码执行时,我可以在Web界面中看到一个峰值,显示已收到某些内容,但我无法看到已接收的内容。当我尝试读取时,无法读取并出现以下错误:
< in route: Route(route2)[[From[rabbitmq:// 192.168.59.103:5672 / rt ...因为Route route2没有输出处理器。您需要添加路线的输出,例如to(“log:foo”)。
是否有人能够提供一个实际的例子,告诉我如何发送消息,查看它并读取它?任何展示此过程的教程也将不胜感激。
谢谢
=================第二部分
我现在遇到的错误是:
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; reason: {#method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - cannot redeclare exchange 'rhSearchExchange' in vhost '/' with different type, durable, internal or autodelete value, class-id=40, method-id=10), null, ""}
at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:33)
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:343)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:216)
at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
... 47 more
我有以下设置:
我遇到了以下错误,我相信我在URI方面做错了一些事情,并且我必须定义一些我缺少的额外参数
我的交换机是直接类型
我的队列是持久类型
我的URI是:
rabbitmq://192.168.59.105:5672/rhSearchExchange?username=guest&password=guest&routingKey=rhSearchQueue
对此有什么建议吗?
谢谢。
from("rabbitmq:localhost...");
但它应该是from("rabbitmq:localhost:...").to("foo:bar")
foo:bar
可以是类似于mock:result
的东西。 - Jeff