10
votes

Comment supprimez-vous une liaison à la file d'attente de Rabbitmq?

J'utilise Rabbitmq pour acheminer des messages aux abonnés intéressés par sujet. Chaque abonné a une file d'attente et je lie la file d'attente aux sujets qui s'intéressent. Je voudrais permettre à l'utilisateur de supprimer un élément de leur liste de sujet.

Dans ma configuration, cela nécessiterait des "engorages" le sujet lié de la file d'attente de cette utilisateur.

J'utilise Pyamqplib et je ne vois pas un moyen de le faire via l'objet de la chaîne. Est leur moyen de supprimer les clés de routage précédemment liées d'une file d'attente?

rabbitmq amqp py-amqplib

0 commentaires

3 Réponses :

1
votes

Est-ce que ceci

Supprimer sélectivement les messages d'une file d'attente AMQP (rabbbitmq)?

Résoudre votre problème?

0 commentaires

5
votes

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

0 commentaires

2
votes

Travailler dans Python?

me regarde comme Pika 0.13 a un METHODE DEBIND : P>

queue_unbind(queue, exchange=None, routing_key=None, arguments=None, callback=None)

0 commentaires