Estou tentando implementar ouvintes bloqueados no RabbitMQ usando o RabbitTemplate do Spring AMQP. No meu código, estou usando o arquivo jar da versão Spring-amqp 1.1.3, enquanto analisei a versão 1.3.1 também e isso também não é suportado nesta versão. Alguém sabe se estou faltando alguma versão que tenha suporte para registrar ouvintes bloqueados para as novas conexões no RabbitMQ. Ou se há alguma versão futura do spring amqp para suportar esse recurso.

Código de exemplo:

    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();