On 11/15/2011 10:15 PM, dmounessa wrote:
Thanks for your help.
Do you mean, I would use " qpid-config [OPTIONS] add exchange<type> <name>
[AddExchangeOptions]" to add my own exchange (instead of amq.topic) and
then use that in my property file?
Yes
-- I.e I would do the following for each topic:
qpid-config add exchange NODE0_EXCHANGE
And then I would set Destination.NODE0 = NODE0_EXCHANGE
You need to specify a type for the exchange to qpid-config. WHat type
you choose depends on the nature of the matching you need. Using type
topic gives you hierarchical wildcard matching, if you don't need any
sophisticated matching you can use fanout.
Can I do this in my own JAVA client, dynamically?
You can, e.g. by using the following as the address in the config file:
NODE0_EXCHANGE; {create: always, node:{type:topic}}
That creates a topic exchange by default, to create a fanout exchange
you would use:
NODE0_EXCHANGE; {create: always, node:{type:topic,
x-declare:{type:fanout}}}
Also, so what is the purpose of topic-name with amq.topic,
if every consumer receives all the messages that are passed on amq.topic
"exchange"?
I'm not entirely sure... the spec requires it, I think just to make
getting started easy.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]