On 02/02/2015 11:24 PM, Jakub Scholz wrote:
Hi,
While playing with the C++ qpid.messaging client and the Java broker (both
from release 0.30), I noticed that the fetch() command with a timeout never
timeouts. It seems to be reproducible even with the qpid-receive:
qpid-receive -b admin/[email protected]:5672 -a "testQueue; { node: {
type: queue } }" --timeout 10 --connection-options "{protocol: amqp1.0}"
From the log it looks like the Java broker doesn't properly implement the
"synchronous get" feature and keeps the client hanging.
Yes, it looks like it is not responding to the drain request. You can
try Receiver::get() instead of fetch to workaround that if you need to.
(The difference is that get will return at the end of the timeout
without trying to 'flush' out its credit).
Is this known issue
or should I raise a JIRA?
That would be great, thanks! (I couldn't find an existing one describing
the issue and in the event its a duplicate, its easy to close).
Thanks & Regards
Jakub
[vagrant@localhost ~]$ qpid-receive -b admin/[email protected]:5672 -a
"testQueue; { node: { type: queue } }" --timeout 10 --connection-options
"{protocol: amqp1.0}"
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 writing protocol
header: 1-0
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 read protocol
header: 1-0
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 Received
SASL-MECHANISMS(CRAM-MD5 )
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 Sent
SASL-INIT(CRAM-MD5, null, 192.168.33.1)
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 Received
SASL-CHALLENGE(46 bytes)
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 Sent
SASL-RESPONSE(admin d57002773e3649eb2ee1e628f7e67b13)
2015-02-02 23:21:47 [Protocol] debug tcp:192.168.33.1:5672 Received
SASL-OUTCOME(\x00)
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: <- AMQP
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: -> AMQP
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 -> @open(16)
[container-id="572afd7a-ddad-4d58-8dfe-99f747162284",
properties={:"qpid.client_process"="qpid-receive",
:"qpid.client_pid"=15027, :"qpid.client_ppid"=1938}]
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 <- @open(16)
[container-id="fb3f1523-f85c-4c46-997b-e637c17014a9", max-frame-size=32768,
channel-max=255, properties={:product="qpid", :version="0.30",
:"qpid.build"="Unversioned directory", :"qpid.instance_name"="Broker"}]
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 -> @begin(17)
[next-outgoing-id=0, incoming-window=2147483647, outgoing-window=0]
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 <- @begin(17) [remote-channel=0,
next-outgoing-id=0, incoming-window=2048, outgoing-window=2048]
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 -> @attach(18)
[name="testQueue_46e96608-19ae-49cd-a7d2-ae6e1d6afa3b", handle=0,
role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="testQueue", durable=0, timeout=0, dynamic=false,
capabilities=:queue], target=@target(41) [address="testQueue", durable=0,
timeout=0, dynamic=false], initial-delivery-count=0]
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 <- @attach(18)
[name="testQueue_46e96608-19ae-49cd-a7d2-ae6e1d6afa3b", handle=0,
role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="testQueue", durable=0, timeout=0, dynamic=false,
capabilities=@PN_SYMBOL[:queue]], target=@target(41) [address="testQueue",
durable=0, timeout=0, dynamic=false], initial-delivery-count=0]
2015-02-02 23:21:47 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 -> @flow(19) [next-incoming-id=0,
incoming-window=2147483647, next-outgoing-id=0, outgoing-window=0,
handle=0, delivery-count=0, link-credit=1000, drain=false]
2015-02-02 23:21:57 [Protocol] trace
[572afd7a-ddad-4d58-8dfe-99f747162284]: 0 -> @flow(19) [next-incoming-id=0,
incoming-window=2147483647, next-outgoing-id=0, outgoing-window=0,
handle=0, delivery-count=0, link-credit=1000, drain=true]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
