0

我有一个非常简单的场景。我创建一个队列，交换并将队列绑定到交换。

Code :
String queueName = new StringBuilder("LP.DATA.").append("TESTACCOUNT").append(".").append("subLP").toString();
channel.exchangeDeclare(ExchangeConstants.DATA_EXCG, "direct", true);
channel.queueDeclare(queueName, true, false, false, null);
channel.exchangeBind(queueName, ExchangeConstants.DATA_EXCG, queueName);

I get the following error when exchangeBind() is called.

com.rabbitmq.client.ShutdownSignalException: channel error; reason: {#method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange 'LP.DATA.TESTACCOUNT.subLP' in vhost '/', class-id=40, method-id=30), null, ""}

My ExchangeConstants.DATA_EXCG is "DATA_EXCG". Using RabbitMq admin I see that the exchange and queue are all created. From the exception I don't understand why is it looking for exchange with name "LP.DATA.TESTACCOUNT.subLP", this is a queuename.  It seems quite trivial, I am sure I am missing something.

I am using java rabbitmq-client version 3.04.
4

1 回答 1

2 
channel.exchangeBind(java.lang.String destination,
             java.lang.String source,
             java.lang.String routingKey)

此函数将 2 个交换绑定在一起：目标和源都应该是交换。

https://www.rabbitmq.com/releases/rabbitmq-java-client/v3.0.4/rabbitmq-java-client-javadoc-3.0.4/com/rabbitmq/client/Channel.html#exchangeBind(java.lang.字符串，java.lang.String，java.lang.String）

在这里，您应该channel.queueBind改用。

于 2013-05-21T05:38:33.747 回答