Wie entfernen Sie eine Warteschlangenbindung von RabbitMQ?

Question

Ich verwende RabbitMQ, um Nachrichten an interessierte Abonnenten nach Themen zu leiten. Jeder Abonnent hat eine Warteschlange und ich binde die Warteschlange an die Themen, an denen sie interessiert sind. Ich möchte dem Benutzer erlauben, ein Element aus seiner Themenliste zu entfernen.

In meiner Einrichtung würde das "gebunden" Thema von der Warteschlange dieses Benutzers "lösen" müssen.

Ich benutze pyamqplib, und ich sehe keine Möglichkeit, dies über das Kanalobjekt zu tun. Ist es eine Möglichkeit, zuvor gebundene Routing-Schlüssel aus einer Warteschlange zu entfernen?

Answer 1

Ist diese

How to selectively delete messages from an AMQP (RabbitMQ) queue?

Ihr Problem lösen?

Answer 2

public void unsubscribe(String queuename, String topic) throws IOException 
{ 
    ConnectionFactory factory = new ConnectionFactory(); 
    factory.setHost(MQ_HOST); 
    factory.setPort(MQ_PORT); 

    Connection connection = factory.newConnection(); 
    Channel channel = connection.createChannel(); 
    try 
    { 
     channel.exchangeDeclarePassive("Channel name"); 
     channel.queueUnbind(queuename, "Channel name", topic); 
    } 
    finally 
    { 
     handleClose(connection, channel); 
    } 
}