Wie aufzuhören Nachricht von selektiven queue RabbitMQ
QueueingConsumer consumer = new QueueingConsumer(channel);
System.out.println(consumer.getConsumerTag());
channel.basicConsume("queue1", consumer);
channel.basicConsume("queue3", consumer);
Ist es möglich, aufzuhören die Nachrichten aus der Warteschlange "queue3" allein dynamisch?
Du musst angemeldet sein, um einen Kommentar abzugeben.
Ja, Sie können, mit
channel.basicCancel(consumerTag);
BEARBEITEN
Zum Beispiel:
Hier finden Sie einen code, Abmelden Verbraucher nach 5 Sekunden:
Ich hoffe, es kann nützlich sein.