One of my processes creates an instance of the Messenger to listen for incoming
messages:
self.messenger = Messenger()
self.messenger.timeout = timeout
self.messenger.subscribe('amqp://~localhost:8888/incoming')
self.messenger.start()
msg = Message()
reply = Message()
while True:
if self.messenger.incoming < 10:
self.messenger.recv(10)
if self.messenger.incoming > 0:
self.messenger.get(msg)
if msg.reply_to:
reply.address = msg.reply_to
reply.correlation_id = msg.correlation_id
reply.body = msg.body
reply.durable = True
self.messenger.put(reply)
self.messenger.send()
I have another Python process that does the same thing except the only
difference is the subscribe line:
self.messenger.subscribe('amqp://~localhost:8888/outgoing')
And then I have another process that tries to connect to the incoming queue and
send a message:
self.messenger = Messenger()
self.messenger.start()
msg = Message()
msg.address = self.address
msg.body = data
msg.properties = props
msg.durable = True
self.messenger.put(msg)
self.messenger.send()
Thanks,
Taylor
________________________________
From: Rafael Schloming [r...@alum.mit.edu]
Sent: Thursday, January 17, 2013 11:10 AM
To: proton@qpid.apache.org
Subject: Re: Subscribing to multiple queue names on the same host/port
On Thu, Jan 17, 2013 at 10:06 AM, Eagy, Taylor <te...@blackbirdtech.com>wrote:
> One of the nice things I liked about the Java Qpid broker was that you
> could create multiple queues bound on the same host:port using the
> virutualhosts.xml config. When I try subscribing to
> amqp://localhost:8888/incoming and amqp://localhost:8888/outgoing, it
> complains that the address is already in use. Does the Messenger API
> support multiple queues per host:port? Also are there any plans for Proton
> to load config file similar to the Qpid brokers?
>
Can you post a code snippet of what you're trying to do?
--Rafael
