You can see that the client granted 1 credit (presumably when you
called fetch) for the broker to send a message, then received a
message, granted another credit and accepted the first message, but
then didn't receive any more messages. Looks like
https://issues.apache.org/jira/browse/AMQ-6422.
On 21 September 2016 at 08:10, jporras <fjavier.por...@gmail.com> wrote:
> Hi , thanks for your answer. Find below log trace from the process ..
>
> Best regards, Javier
>
> javier@draco $ cat log.txt
> [0x7911e0]: -> AMQP
> [0x7911e0]: <- AMQP
> [0x7911e0]:0 -> @open(16)
> [container-id="62b1050c-8b62-412c-9c68-30574005db10", channel-max=32767,
> properties={:"qpid.client_process"=:"hello_world", :"qpid.client_pid"=2319,
> :"qpid.client_ppid"=1865}]
> [0x7911e0]:0 <- @open(16) [container-id="localhost",
> max-frame-size=4294967295, channel-max=32767, idle-time-out=15000,
> offered-capabilities=@PN_SYMBOL[:"ANONYMOUS-RELAY"],
> properties={:product="ActiveMQ", :"topic-prefix"="topic://",
> :"queue-prefix"="queue://", :version="5.14.0", :platform="Java/1.8.0_101"}]
> [0x7911e0]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647,
> outgoing-window=2147483647]
> [0x7911e0]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
> incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535]
> [0x7911e0]:0 -> @attach(18)
> [name="REQ.SV1.TIMEOUT_1_f01b8af4-23b4-41e1-a999-23433b3464e6", handle=0,
> role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0, dynamic=false],
> target=@target(41) [address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0,
> dynamic=false], initial-delivery-count=0]
> [0x7911e0]:0 <- @attach(18)
> [name="REQ.SV1.TIMEOUT_1_f01b8af4-23b4-41e1-a999-23433b3464e6", handle=0,
> role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="REQ.SV1.TIMEOUT_1"], target=@target(41)
> [address="REQ.SV1.TIMEOUT_1"], incomplete-unsettled=false,
> initial-delivery-count=0]
> [0x7911e0]:0 -> @attach(18)
> [name="REQ.SV1.TIMEOUT_1_92297aa4-3062-432a-9570-2bd51d1546f8", handle=1,
> role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0, dynamic=false],
> target=@target(41) [address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0,
> dynamic=false], initial-delivery-count=0]
> [0x7911e0]:0 <- @attach(18)
> [name="REQ.SV1.TIMEOUT_1_92297aa4-3062-432a-9570-2bd51d1546f8", handle=1,
> role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
> [address="REQ.SV1.TIMEOUT_1"], target=@target(41)
> [address="REQ.SV1.TIMEOUT_1"]]
> [0x7911e0]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647,
> next-outgoing-id=1, outgoing-window=2147483647, handle=1, delivery-count=0,
> link-credit=1000]
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=0,
> delivery-tag=b"\x00\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=1,
> delivery-tag=b"\x01\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=2,
> delivery-tag=b"\x02\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=3,
> delivery-tag=b"\x03\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=4,
> delivery-tag=b"\x04\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=5,
> delivery-tag=b"\x05\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=6,
> delivery-tag=b"\x06\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=7,
> delivery-tag=b"\x07\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=8,
> delivery-tag=b"\x08\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 -> @flow(19) [next-incoming-id=1, incoming-window=2147483647,
> next-outgoing-id=9, outgoing-window=2147483647, handle=0, delivery-count=0,
> link-credit=1, drain=false]
> [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=9,
> delivery-tag=b"\x09\x00\x00\x00", message-format=0, settled=false,
> more=false] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=1, last=1, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=2, last=2, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=3, last=3, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=4, last=4, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=5, last=5, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=6, last=6, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=7, last=7, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @disposition(21) [role=true, first=8, last=8, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"0",
> message-format=0] (32)
> "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!"
> [0x7911e0]:0 <- @disposition(21) [role=true, first=9, last=9, settled=true,
> state=@accepted(36) []]
> Hello world!
> [0x7911e0]:0 -> @flow(19) [next-incoming-id=2, incoming-window=2147483647,
> next-outgoing-id=10, outgoing-window=2147483647, handle=0, delivery-count=1,
> link-credit=1, drain=false]
> [0x7911e0]:0 -> @disposition(21) [role=true, first=0, last=0, settled=true,
> state=@accepted(36) []]
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
> [0x7911e0]:0 -> (EMPTY FRAME)
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/AMQP-client-does-not-deque-messages-tp4716649p4716680.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
