Qpid für Python, nicht für ein Thema abonnieren

Question

Mit Qpid für Python verwende ich den Container, um eine Verbindung zu ActiveMq mit der Connector-URL wie folgt herzustellen:
Benutzername: Passwort @ Hostname: 5672/topicName.
In der Webkonsole kann ich sehen, dass für AMQP die Verbindung besteht. Anstatt jedoch ein bestehendes Thema zu abonnieren, wird eine neue Warteschlange mit diesem Namen erstellt.

Kann mir jemand in dem Format helfen, das gegeben werden muss, um ein Thema zu abonnieren. Oder, wenn ich etwas vermisse, bitte zeige mir in die richtige Richtung.

Vielen Dank.

Answer 1

Ich bin nicht ganz sicher über die Qpid für Python-URI-Syntax, aber von der ActiveMQ-Seite wird ein Ziel direkt mit einem Ziel-Präfix adressiert. Für ein Thema ist das Präfix topic: // und für die Warteschlange ist es queue: // nicht überraschend. In Abwesenheit eines Präfixes setzt der Broker die betreffende Adresse auf einen Warteschlangentyp, da dies im Allgemeinen die Präferenz ist.

Um Ihr Problem zu beheben, müssen Sie einen URI erstellen, der das korrekte Präfix verwendet, was in Ihrem Fall etwas mit topic: // some-name wäre und das Ihnen die erwarteten Ergebnisse bringen sollte.

Answer 2

Fand heraus, dass das Problem war, In On_start Methode müssen wir verwenden event.container.create_receiver() und die URL hat im Format Thema sein: //