ログシンクストリームのアプリケーション依存関係のある私のカスタムSpringクラウドストリームシンクが、RabbitMQ停止中にRabbitMQ接続を失い、5回接続しようとしてから消費者を停止することがわかりました。私は手動でRabbitMQがアップしたら、それが正常に接続するために、アプリケーションを手動で再起動する必要があります。私がrabbitMQバインディングhereのデフォルトのプロパティを見ると、それはインターバル時間を与えますが、無限の再試行のプロパティはありません(これはデフォルトの動作と想定しています)。誰かが私が無限に接続しようとするためにここで行方不明になるかもしれないことを私に教えてもらえますか?Springクラウドストリーム:SinkがRabbitMQ接続を失う
Error faced during outage triggering consumer retry :
2017-08-08T10:52:07.586-04:00 [APP/PROC/WEB/0] [OUT] Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - home node '[email protected]' of durable queue 'datastream.dataingestor.datastream' in vhost '8880756f-8a21-4dc8-9b97-95e5a3248f58' is down or inaccessible, class-id=50, method-id=10)
5回ではなく3回後に同様の問題が発生しています。明らかに、これは 'SimpleMessageListenerContainer'のデフォルト値です(https://docs.spring.io/spring-amqp/docs/1.7.4.RELEASE/reference/htmlsingle /#containerAttributes)。何とかこの番号を上書きしていますか? –