根据我(有限的)使用rabbit-mq的经验,如果你为一个尚不存在的队列创建新的监听器,该队列会自动创建。我正在尝试使用Spring AMQP项目和rabbit-mq来设置一个监听器,但是却收到了错误提示。以下是我的xml配置:
<rabbit:connection-factory id="rabbitConnectionFactory" host="172.16.45.1" username="test" password="password" />
<rabbit:listener-container connection-factory="rabbitConnectionFactory" >
<rabbit:listener ref="testQueueListener" queue-names="test" />
</rabbit:listener-container>
<bean id="testQueueListener" class="com.levelsbeyond.rabbit.TestQueueListener">
</bean>
我在RabbitMq日志中看到了以下内容:
=ERROR REPORT==== 3-May-2013::23:17:24 ===
connection <0.1652.0>, channel 1 - soft error:
{amqp_error,not_found,"no queue 'test' in vhost '/'",'queue.declare'}
AMQP 也会出现类似的错误:
2013-05-03 23:17:24,059 ERROR [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] (SimpleAsyncTaskExecutor-1) - Consumer received fatal exception on startup
org.springframework.amqp.rabbit.listener.FatalListenerStartupException: Cannot prepare queue for listener. Either the queue doesn't exist or the broker will not allow us to use it.
从堆栈跟踪中看,队列是以“被动”模式创建的-有谁能指出我如何创建队列而不使用被动模式,以便我不会看到这个错误?或者我还遗漏了其他什么吗?