Recv and Send

[Louis Letourneau <ll...@gmail.com>]

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
Louis

Re: Recv and Send

[Louis Letourneau <ll...@gmail.com>]

>
> 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.
>
>
thank you, it was actually my receiver that had an issue with prefetch and
flow.

Re: Recv and Send

[Gordon Sim <gs...@redhat.com>]

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: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org