-
1. Consume messages from multiple queues over single session
clebert.suconic May 4, 2011 12:17 PM (in response to mateusz.gajewski)Take a look on Topic Hierarchy example. Is that what you're looking for?
-
2. Consume messages from multiple queues over single session
clebert.suconic May 4, 2011 1:47 PM (in response to clebert.suconic)BTW: Topic Hierarchy should definitely be what you're looking for.
You create a subscription from multiple queues using wildcards and receive messages on it.
-
3. Consume messages from multiple queues over single session
mateusz.gajewski May 4, 2011 2:27 PM (in response to mateusz.gajewski)As I understand JMS: topic is not a queue. Topic is rather "broadcast" channel where multiple consumers gets the same piece of information (unlike queue when message is consumed by one subscriber).
Also in documentation there's no information where can I use wildcards:
i.e. ClientConsumer createConsumer(String queueName, String filter, int windowSize, int maxRate, boolean browseOnly) throws HornetQException
queueName
- name of the queue to consume messages fromThere's also no information that topic hierarchy is implemented as queues hierarchy (no info in doc or apidoc)
-
4. Consume messages from multiple queues over single session
clebert.suconic May 4, 2011 10:12 PM (in response to mateusz.gajewski)You would need to create a Queue with a wildcard. I'm not sure now if it would work with jms.queues. I believe it should, but I would need to check.
May Andy Taylor will know on top of his head as he worked on it. If he doesn't know I will look tomorrow.
You will basically have to create a queue (temporary or not), and then you will have to consume of it.
-
5. Consume messages from multiple queues over single session
mateusz.gajewski May 5, 2011 4:31 AM (in response to clebert.suconic)I figured out that by creating queue with wilcard adress (using core API) I'm able to consume messages from different addresses at once using single consumer (and still these behaves as queues - not topics).
Another question rised if I am able to pause address (using management API) - in docs I have found that I can pause queue (QueueImp.java) but I think that I can't do this for address. I'm right?
-
6. Re: Consume messages from multiple queues over single session
clebert.suconic May 5, 2011 9:15 AM (in response to mateusz.gajewski)You never consume from an address, so there's no point on pausing a address.
Unless you meant stop all queues on an address? I don't think we have such operation.
-
7. Consume messages from multiple queues over single session
mateusz.gajewski May 5, 2011 9:04 AM (in response to clebert.suconic)Yes, you're right: I consume messages from queue bound to single or hierarchy of addresses. I can pause queue (so I will not consume from given address or hierarchy of addresses) but I can't pause consuming messages from subtree in adress hierarchy.
i.e.
queue "test" bound to address "test.#"
queue "testUser" bound to adress "test.user"
queue "testSomething" bound to address "test.something"
I want to consume messages from queue "test" (test.# address) but I also want to have ability to say "please don't consume messages on test.user for a while"
I think that pausing address consuming is a more general/abstract approach than pausing a queue