问题描述
如果用户名不正确,密码错误或QueueName不存在,通道将停止,因为该通道在打开连接期间收到致命异常。该消息已记录且有效。
但是,在虚拟主机损坏或主机名不正确的情况下,我们不会记录错误或FatalException来终止我的Java进程。
遵循我的代码:
<bean id="connectionAmqpFactorySrc" class="com.rabbitmq.client.ConnectionFactory">
<property name="automaticRecoveryEnabled" value="false"/>
</bean>
<rabbit:connection-factory id="rabbitConnectionFactory" connection-factory="connectionAmqpFactorySrc"
username="${INBOUND_USER}"
password="${INBOUND_PASSWORD}"
addresses="${INBOUND_ADDRESSES}"
cache-mode="CHANNEL"
virtual-host="${INBOUND_VIRTUALHOST}" connection-timeout="10000" />
<int-amqp:inbound-channel-adapter channel="channelRmqMQ"
queue-names="${INBOUND_QUEUE_NAME}"
connection-factory="rabbitConnectionFactory"
id="inboundChannelAdapter"
channel-transacted="true"
concurrent-consumers="${INBOUND_CONCURRENT_CONSUMERS}"
prefetch-count="${INBOUND_PREFETCH_COUNT}"
error-channel="processChannel1"
missing-queues-fatal="true"
/>
编辑
消息像Debug一样记录:
DEBUG o.s.a.r.l.SimpleMessageListenerContainer - Consumer raised exception,processing can restart if the connection factory supports it
org.springframework.amqp.AmqpIOException: java.net.UnkNownHostException:
与虚拟主机相同。 然后尝试在5000毫秒内恢复使用者。
ERROR o.s.a.r.l.SimpleMessageListenerContainer - Consumer received fatal=false exception on startup
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404,reply-text=NOT_FOUND - no queue
END EDIT
感谢您的帮助,
致谢
埃里克
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)