Need qpid-proton publish/subscribe amqp sample program for python to access Azure topic -
i using azure cloud service bus send , receive messages using amqp protocol. have installed proton-c libraries in debian-linux. tried below programme send , receive message queue. requirement instead of queue have utilize topics. please give me sample programme utilize topics in azure cloud.
import sys, optparse proton import * messenger = messenger() message = message() message.address = "amqps://owner:<<key>>@namespace.servicebus.windows.net/queuename" message.body = "sending message queue" messenger.put(message) messenger.send() instead of queuename in above url if give topic name programme running forever. please help me. new python programming.
i found myself solution problem. guess few people working in azure cloud didn't answers.
here solution:
if create topics in azure service bus, select checkbox "enable partitioning". amqp protocol doesn't back upwards partitioning topics/queues stuck above issue. 1 time deleted topic , recreate same topic without select checkbox "enable partitioning". work fine. :)
python-2.7 azure amqp azureservicebus qpid
No comments:
Post a Comment