Broker-J topic example with rhea.js

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Broker-J topic example with rhea.js

fea17e86
Hi,

I'm trying to get a publish subscribe example with Broker-J and  rhea.js
<https://github.com/amqp/rhea>   to work.

First I created a few queues bound to the default exchange "amq.topic":

<http://qpid.2158936.n2.nabble.com/file/t396448/broker-j_config.png>

Then I created a publisher with rhea.js: https://pastebin.com/4MWe1Qgh it is
a modified version of the rhea.js  publisher
<https://github.com/amqp/rhea/blob/master/examples/durable_subscription/publisher.js>  
and  subscriber
<https://github.com/amqp/rhea/blob/master/examples/durable_subscription/subscriber.js>  
example.

Unfortunately it doesn't work, a Could not find destination for target
'Target{address=objects.bed.update,durable=none}' error is thrown:
https://pastebin.com/AifSYHGs

Can anybody please help me with figuring out which host name and topic name
to use? Any help would be appreaciated!

Best regards
Tobi



--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html

---------------------------------------------------------------------
To unsubscribe, e-mail: [hidden email]
For additional commands, e-mail: [hidden email]

Reply | Threaded
Open this post in threaded view
|

Re: Broker-J topic example with rhea.js

rgodfrey
On Fri, 7 Jun 2019 at 16:24, fea17e86 <[hidden email]> wrote:

> Hi,
>
> I'm trying to get a publish subscribe example with Broker-J and  rhea.js
> <https://github.com/amqp/rhea>   to work.
>
> First I created a few queues bound to the default exchange "amq.topic":
>
> <http://qpid.2158936.n2.nabble.com/file/t396448/broker-j_config.png>
>
> Then I created a publisher with rhea.js: https://pastebin.com/4MWe1Qgh it
> is
> a modified version of the rhea.js  publisher
> <
> https://github.com/amqp/rhea/blob/master/examples/durable_subscription/publisher.js>
>
> and  subscriber
> <
> https://github.com/amqp/rhea/blob/master/examples/durable_subscription/subscriber.js>
>
> example.
>
> Unfortunately it doesn't work, a Could not find destination for target
> 'Target{address=objects.bed.update,durable=none}' error is thrown:
> https://pastebin.com/AifSYHGs
>
> Can anybody please help me with figuring out which host name and topic name
> to use? Any help would be appreaciated!
>
> Best regards
> Tobi
>
>
"objects.bed.update" is a binding to amq.topic, it is not an an address in
itself.

You should be able to send to the address "amq.topic/objects.bed.update"
(i.e. <exchange>/<routing key>) to achieve what you want

-- Rob


>
>
> --
> Sent from:
> http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [hidden email]
> For additional commands, e-mail: [hidden email]
>
>
Reply | Threaded
Open this post in threaded view
|

Re: Broker-J topic example with rhea.js

fea17e86
Great, thank you, that worked! :)



--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html

---------------------------------------------------------------------
To unsubscribe, e-mail: [hidden email]
For additional commands, e-mail: [hidden email]