<div dir="ltr"><div>Hi Bob,</div><div> </div><div>Could you share the YAML used for the topic and the subscription? I'd like to see if I can reproduce your issue.</div><div> </div><div>Best regards,</div><div> </div><div>Ulf </div></div> <div class="gmail_quote"><div dir="ltr" class="gmail_attr">On Fri, Jan 25, 2019 at 3:43 PM Bob Claerhout <<a href="mailto:bob.claerhout@aloxy.io">bob.claerhout@aloxy.io</a>> wrote: </div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex">I'm getting following logging when subscribing to topic::subscription $ qb message receive topic::subscription -b amqp://user:secret@localhost:5672 [0x1d7a6d0]: -> SASL [0x1d7a6d0]: <- SASL [0x1d7a6d0]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:PLAIN, :"SCRAM-SHA-1", :"XOAUTH2"]] [0x1d7a6d0]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\x00user\x00secret"] [0x1d7a6d0]:0 <- @sasl-outcome(68) [code=0] [0x1d7a6d0]: -> AMQP [0x1d7a6d0]:0 -> @open(16) [container-id="cda0f467-75fb-4af0-847d-d5bb3a99a39a", hostname="localhost", channel-max=32767] [0x1d7a6d0]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1d7a6d0]:0 -> @attach(18) [name="cda0f467-75fb-4af0-847d-d5bb3a99a39a-topic::subscription-60486f5c-8eea-4144-92bc-94d1b8db3683", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="topic::subscription", durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0] [0x1d7a6d0]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10, drain=false] [0x1d7a6d0]: <- AMQP [0x1d7a6d0]:0 <- @open(16) [container-id="qdrouterd-aloxy-0", max-frame-size=16384, channel-max=32767, idle-time-out=8000, offered-capabilities=:"ANONYMOUS-RELAY", properties={:product="qpid-dispatch-router", :version="1.4.1", :"qd.conn-id"=26528}] [0x1d7a6d0]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1d7a6d0]:0 <- @attach(18) [name="cda0f467-75fb-4af0-847d-d5bb3a99a39a-topic::subscription-60486f5c-8eea-4144-92bc-94d1b8db3683", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, target=@target(41) [durable=0, timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0] [0x1d7a6d0]:0 <- @detach(22) [handle=0, closed=true, error=@error(29) [condition=:"amqp:not-found", description="Node not found"]] [0x1d7a6d0]:0 -> @detach(22) [handle=0, closed=true] [0x1d7a6d0]:0 -> @close(24) [] [0x1d7a6d0]: -> EOS [0x1d7a6d0]:0 <- @close(24) [] [0x1d7a6d0]: <- EOS It is saying: "Node not found". When I subscribe to topic, I'm getting the following (which is successful): $ qb message receive topic -b amqp://user:secret@localhost:5672 -c 100 [0x1197590]: -> SASL [0x1197590]: <- SASL [0x1197590]:0 <- @sasl-mechanisms(64) [sasl-server-mechanisms=@PN_SYMBOL[:PLAIN, :"SCRAM-SHA-1", :"XOAUTH2"]] [0x1197590]:0 -> @sasl-init(65) [mechanism=:PLAIN, initial-response=b"\x00user\x00secret"] [0x1197590]:0 <- @sasl-outcome(68) [code=0] [0x1197590]: -> AMQP [0x1197590]:0 -> @open(16) [container-id="e33d7c15-83f6-4f72-9590-6536ba7953e3", hostname="localhost", channel-max=32767] [0x1197590]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1197590]:0 -> @attach(18) [name="e33d7c15-83f6-4f72-9590-6536ba7953e3-topic-a6f9e685-b5e6-4a4d-a275-ca9156a31ce1", handle=0, role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="topic", durable=0, timeout=0, dynamic=false], target=@target(41) [durable=0, timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0] [0x1197590]:0 -> @flow(19) [incoming-window=2147483647, next-outgoing-id=0, outgoing-window=2147483647, handle=0, delivery-count=0, link-credit=10, drain=false] [0x1197590]: <- AMQP [0x1197590]:0 <- @open(16) [container-id="qdrouterd-aloxy-0", max-frame-size=16384, channel-max=32767, idle-time-out=8000, offered-capabilities=:"ANONYMOUS-RELAY", properties={:product="qpid-dispatch-router", :version="1.4.1", :"qd.conn-id"=26550}] [0x1197590]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=0, incoming-window=2147483647, outgoing-window=2147483647] [0x1197590]:0 <- @attach(18) [name="e33d7c15-83f6-4f72-9590-6536ba7953e3-topic-a6f9e685-b5e6-4a4d-a275-ca9156a31ce1", handle=0, role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40) [address="topic", durable=0, expiry-policy=:"session-end", timeout=0, dynamic=false], target=@target(41) [durable=0, expiry-policy=:"session-end", timeout=0, dynamic=false], initial-delivery-count=0, max-message-size=0] Kind regards, Bob On 1/24/19 6:00 PM, <a href="mailto:enmasse-request@redhat.com" target="_blank">enmasse-request@redhat.com</a> wrote: > > Message: 1 > Date: Thu, 24 Jan 2019 13:38:52 +0000 > From: Gordon Sim <<a href="mailto:gsim@redhat.com" target="_blank">gsim@redhat.com</a>> > To: <a href="mailto:enmasse@redhat.com" target="_blank">enmasse@redhat.com</a> > Subject: Re: [EnMasse] Topics and subscriptions in Enmasse 0.24.1 > Message-ID: <<a href="mailto:83c2cbd1-c04d-d4e1-0a13-f69aaf9d796c@redhat.com" target="_blank">83c2cbd1-c04d-d4e1-0a13-f69aaf9d796c@redhat.com</a>> > Content-Type: text/plain; charset=utf-8; format=flowed > > On 24/01/19 13:24, Bob Claerhout wrote: >> Hi Rob, >> >> I'm sorry for the delay but I have tested this again today. >> I cannot subscribe to topic::subscription. I'm not getting an error. The >> amqp client (qpid -bow in this case) just returns without receiving any >> messages. > Could you run that with the environment variable PN_TRACE_FRM=1? That > will show the protocol trace and may give some further clues. > >> I double checked today and I'm receiving each message twice when I >> subscribe to topic/# which isn't correct either. > > > ------------------------------ > > _______________________________________________ > enmasse mailing list > <a href="mailto:enmasse@redhat.com" target="_blank">enmasse@redhat.com</a> > <a href="https://www.redhat.com/mailman/listinfo/enmasse" rel="noreferrer" target="_blank">https://www.redhat.com/mailman/listinfo/enmasse</a> > > > End of enmasse Digest, Vol 22, Issue 8 > ************************************** _______________________________________________ enmasse mailing list <a href="mailto:enmasse@redhat.com" target="_blank">enmasse@redhat.com</a> <a href="https://www.redhat.com/mailman/listinfo/enmasse" rel="noreferrer" target="_blank">https://www.redhat.com/mailman/listinfo/enmasse</a> </blockquote></div>