Comment arrêter de consommer de la message d'une sélection de la file d'attente - RabbitMQ

QueueingConsumer consumer = new QueueingConsumer(channel);
System.out.println(consumer.getConsumerTag());
channel.basicConsume("queue1", consumer);
channel.basicConsume("queue3", consumer);

Est-il possible de cesser de consommer les messages de la file d'attente "queue3" seul dynamiquement?

OriginalL'auteur user1182253 | 2014-04-28

  1. 20

    Oui, vous pouvez, à l'aide de channel.basicCancel(consumerTag);
    MODIFIER
    Par exemple: 

    String tag3 = channel.basicConsume("queue3", consumer);
channel.basicCancel(tag3)

    Ici vous pouvez trouver un code qui vous désabonner d'un consommateur après 5 secondes:

    String tag1 = channel.basicConsume(myQueue, autoAck, consumer);
String tag2 = channel.basicConsume(myQueue2, autoAck, consumer);
    executorService.execute(new Runnable() {
        @Override
        public void run() {
            while (true) {
                Delivery delivery;
                try {
                    delivery = consumer.nextDelivery();
                    String message = new String(delivery.getBody());
                    System.out.println("Received: " + message);
                } catch (Exception ex) {
                    Logger.getLogger(TestMng.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        }
    });
    System.out.println("Consumers Ready");
    try {
        Thread.sleep(5000);
    } catch (InterruptedException ex) {
        Logger.getLogger(TestMng.class.getName()).log(Level.SEVERE, null, ex);
    }

    channel.basicCancel(tag2); ///here you remove only the Myqueue2

    J'espère que cela peut être utile.

    OriginalL'auteur Gabriele