[EnMasse] Topics and subscriptions in Enmasse 0.24.1

Mon Jan 28 14:00:20 UTC 2019

Hi Bob,

Could you share the YAML used for the topic and the subscription? I'd like
to see if I can reproduce your issue.

Best regards,

Ulf

On Fri, Jan 25, 2019 at 3:43 PM Bob Claerhout <bob.claerhout at aloxy.io>
wrote:

> 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, enmasse-request at redhat.com wrote:
> >
> > Message: 1
> > Date: Thu, 24 Jan 2019 13:38:52 +0000
> > From: Gordon Sim <gsim at redhat.com>
> > To: enmasse at redhat.com
> > Subject: Re: [EnMasse] Topics and subscriptions in Enmasse 0.24.1
> > Message-ID: <83c2cbd1-c04d-d4e1-0a13-f69aaf9d796c at redhat.com>
> > 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
> > enmasse at redhat.com
> > https://www.redhat.com/mailman/listinfo/enmasse
> >
> >
> > End of enmasse Digest, Vol 22, Issue 8
> > **************************************
>
>
> _______________________________________________
> enmasse mailing list
> enmasse at redhat.com
> https://www.redhat.com/mailman/listinfo/enmasse
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://listman.redhat.com/archives/enmasse/attachments/20190128/6d616388/attachment.htm>