Я пытаюсь внедрить блокированные прослушиватели в RabbitMQ, используя RabbitTemplate Spring AMQP. В моем коде я использую файл jar версии Spring-amqp 1.1.3, в то время как я посмотрел и версию 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();