2017-07-13 1 views
0

En utilisant Qpid pour python, j'utilise le conteneur pour me connecter à ActiveMq avec l'URL du connecteur:
nom d'utilisateur: motdepasse @ nomhôte: 5672/topicName.
Dans la console Web, je constate que pour AMQP, la connexion est établie. Mais au lieu de s'abonner à un sujet existant, créez une nouvelle file d'attente avec ce nom. Est-ce que quelqu'un peut m'aider dans le format qui doit être donné pour m'abonner à un sujet? Ou si quelque chose me manque, veuillez me diriger dans la bonne direction.Qpid pour python, Impossible de s'abonner à un sujet

Merci.

Répondre

0

Je ne suis pas entièrement sûr de la syntaxe Qpid pour URI python mais du côté ActiveMQ une destination est adressée directement en utilisant un préfixe de destination. Pour un sujet, le préfixe est sujet: // et pour la file d'attente il est en file d'attente: // sans surprise. En l'absence d'un préfixe, le courtier par défaut l'adresse en question à un type de file d'attente car c'est généralement la préférence. Donc, pour résoudre votre problème, vous devez construire un URI qui utilise le préfixe correct qui dans votre cas serait quelque chose en utilisant topic: // some-name et qui devrait vous obtenir les résultats que vous attendez.

+0

J'avais essayé avec le sujet préfixe: // mais n'a pas fonctionné. –

0

trouvé que la question était, en méthode On_start nous devons utiliser event.container.create_receiver() et l'URL doit être dans le sujet du format: //