I am using qpid proton 0.29 python talking to Active MQ using AMQP 1.0
I am trying to use one container and send messages to multiple queues
def on_start(self, event):
conn_url1 = Url(...)
self.sender1 = event.container.create_sender(conn_url1)
conn_url2 = Url(...)
self.sender2 = event.container.create_sender(conn_url2)
def on_new_data(self, event):
msg = Message(body=event.subject)
print('{}, {}'.format(self.sender1.credit, self.sender2.credit))
if(self.sender1.credit > 0):
self.sender1.send(msg)
else:
print("No credits: sender1")
if(self.sender2.credit > 0):
self.sender2.send(msg)
else:
print("No credits: sender2")
Problem is, sender2 always has 0 credits.
If I create X senders, only the first one created will have credits the
others will always be 0
I only found 2 ways to make this work.
1- Not use containers, but use a BlockingConnection per sender
2- Create one container per sender. Which means many loops, basically one
per connection
Is this normal? Why can't a container manage multiple connections/senders?
Thank you
Louis