On 16/11/2019 11:34 pm, Mike Longfritz wrote:
I have a receiver that is connecting to an apache qpid queue (java-based, I
believe, though that's probably not relevant). The issue I'm finding is
that the receiver gets messages that are currently in the queue when it
connects (there are often many), but that any new messages in the queue are
not getting to the receiver. If I start a new receiver, it sees the missed
messages just fine - but again, any more that come into the queue after the
connection is established are not seen.

Is it that messages that arrive after your poll_for_messages() call returns the first time are not received? Or is the call to that method long enough that messages arriving during the first poll attempt are not being received?

If the former, it may be that you are actually being disconnected, e.g. if the broker is expecting heartbeats. When not in the run() method of the container, proton is doing nothing.


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

Reply via email to