使用 RabbitMQ(Java 客户端)，有没有办法确定消费期间网络连接是否关闭?

I'm using RabbitMQ on RHEL 5.3 using the Java client. I have 2 nodes (machines). Node1 is consuming messages from a queue on Node2 using the Java helper class QueueingConsumer.

QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume("MyQueueOnNode2", noAck, consumer);
while (true)
{
   QueueingConsumer.Delivery delivery = consumer.nextDelivery();
   ... Process message - delivery.getBody()
}

如果接口在 Node1 或 Node2 上关闭(例如 ifconfig eth1 down)，客户端(上图)永远不会知道网络不再存在.RabbitMQ 是否在 Java 客户端上提供某种类型的配置，可用于确定连接是否已消失.关闭 Node2 上的 RabbitMQ 服务器将触发 ShutdownSignalException，可以捕获该异常，并且应用程序可以进入重新连接循环.但是关闭接口不会导致任何类型的异常发生，因此代码将在 consumer.nextDelivery() 上永远等待.

QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume("MyQueueOnNode2", noAck, consumer);
int timeout_ms = 30000;
while (true)
{
   QueueingConsumer.Delivery delivery = consumer.nextDelivery(timeout_ms);
   if (delivery == null)
   {
      if (channel.isOpen() == false)             // Seems to always return true
      { throw new ShutdownSignalException(); }
   }
   else
   {
     ... Process message - delivery.getBody()
   }
}