On 07/11/2019 5:33 pm, Louis Letourneau wrote:
I am using qpid proton 0.29 python talking to Active MQ using AMQP 1.0

This is quite the beginner question. I have read the doc and looked and ran
most of the examples by I cannot get a simple Receiver to Send a message to
another queue.

I have a consumer of a queue do some processing and forward the result to 2
other queues.
The receiver works, it gets its on_message called but then, to send the
result I tried

msg = Message(body={'mymsg': 'results'})
self.sender.send(msg)

where in on_start I have:
conn_url = Url(...)
self.sender = event.container.create_sender(conn_url, conn_url.path)

This doesn't work. If I try having a sender handler, on_sendable gets
called once and never again.

I'm at a loss.
Thanks for any help you can provide


Try running with env var PN_TRACE_FRM=1. That will show what your example is actually transmitting and receving which may provide a clue.


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to