当我的应用程序失去与RabbitMQ的连接时,我将其连接工厂设置为自动尝试重新连接
ConnectionFactory factory = new ConnectionFactory();
factory.setUsername(username);
factory.setPassword(password);
factory.setRequestedHeartbeat(1);
factory.setConnectionTimeout(5000);
factory.setAutomaticRecoveryEnabled(true);
factory.setTopologyRecoveryEnabled(true);
Run Code Online (Sandbox Code Playgroud)
当它试图重新连接它时,它一旦再次连接就永远不会停止阻塞,我不确定为什么.
我使用的是最新版本的java客户端3.3.4
当我通过rabbitmq管理界面强制断开客户端连接时,似乎也会发生这种情况.
一些进一步的研究看起来像它正试图获得一个频道,但网络界面说有一个频道连接.