Spring AMQP：將BlockedListener註冊爲連接

Question

我試圖使用Spring AMQP的RabbitTemplate將Blocked Listeners實現爲RabbitMQ。在我的代碼中，我使用了Spring-amqp 1.1.3版本的jar文件，而我也查看了1.3.1版本，並且這個版本也不支持。有誰知道我是否缺少支持在RabbitMQ中註冊阻塞偵聽器到新連接的任何版本。或者，如果有任何未來版本的spring amqp支持這個功能。

例如代碼：

Connection connection = factory.newConnection(); 
    connection.addBlockedListener(new BlockedListener() { 
    @Override 
    public void handleUnblocked() throws IOException { 
     System.out.println("Connection is Unblocked"); 
    } 

    @Override 
    public void handleBlocked(String arg0) throws IOException { 
     System.out.println("Connection Blocked"); 
    }   



    }); 
    com.rabbitmq.client.Channel channel = connection.createChannel();  

Answer 1

這不是當前可用的開箱;請隨時打開Improvement JIRA Issue。

但是，您可以添加一個Spring AMQP ConnectionListener到CachingConnectionFactory ...

connectionFactory.addConnectionListener(new ConnectionListener() { 

    @Override 
    public void onCreate(Connection connection) { 
     Channel channel = connection.createChannel(false); 
     channel.getConnection().addBlockedListener(new BlockedListener() { 

      @Override 
      public void handleUnblocked() throws IOException { 

      } 

      @Override 
      public void handleBlocked(String reason) throws IOException { 

      } 
     }); 
     try { 
      channel.close(); 
     } 
     catch (IOException e) { 
     } 
    } 

    @Override 
    public void onClose(Connection connection) { 

    } 

}); 

即使當您添加監聽器的連接已經建立它就會被調用。