[EnMasse] Topics and subscriptions in Enmasse 0.24.1

[Bob Claerhout]

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
> **************************************