On 21/09/18 16:15, areddy wrote:
Hello, i'm using MessagingHandler to consume messages off of activemq. This
is my configuration
1. prefetch = 0 and I only process 1 message at a time.
2. auto_accept=False.
3. on_message creates a new thread on every message to "consume" the message
I've noticed that after a random number of messages, 2 disposition frames
are sent out. One without the "settled" flag and one with. This causes the
broker to send it's own disposition frame back, after which the receiver
stops receiving messages.
[...]
Is this a bug ? Or am I using the API incorrectly ?
You are using the API incorrectly. Connections are not threadsafe so it
is not safe to invoke on them from one thread while the event thread is
processing them.
One approach is that used by the db_send/db_recv examples:
https://git1-us-west.apache.org/repos/asf/qpid-proton/repo?p=qpid-proton.git;a=blob;f=python/examples/db_recv.py;h=8c7904980914417c7cfb4fa72ce75607da99631a;hb=HEAD
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
