Re: Concurrent message consumption in ActiveMQ

Are you saying you want C1 to consume only P1's messages and C2 to consume only P2's messages? In that case either use selectors or message groups (but I think there's a risk that one consumer will end up with both groups and the other will sit idle) or two separate queues. Selectors are probably

Re: How do i connect a glassfish server 4 to an external activeMQ 5.11?

What does "connect" mean in this context? On May 6, 2015 8:08 AM, "Angel Guerra" wrote: > I need help with this topic please > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/How-do-i-connect-a-glassfish-server-4-to-an-external-activeMQ-5-11-tp4696156.html > Sent

Re: Does JMS priority work with “small" maxPageSize ?

Ouch. OK. I think a lot of these behaviors might need to be documented a bit better, or maybe added as edge cases to be fixed in 6.0. I imagine KahaDB could do this internally but I’m not sure. I think we might just end up having 2 or 3 queue priorities implemented by using different physical qu

JMSException: Queue does not exist

I want to create a basic MessageProducer who sends a message and MessageConsumer who receives the message asynchronously. MessageProducer.java MessageConsumer.java My ActiveMQServer as a broker. Server.java

Concurrent message consumption in ActiveMQ

Hi, I use a ActiveMQServer as a broker. Server.java and I have a Client.java class, where I create a queue, message producer and message consumer. Client.java In this main I create one queue, two producers and two consumers. mai

Thread behaviour for persistence and non-persistence messages

Hi, Does ActiveMQ uses parallel threads for queuing the messages for persistence and non-persistence messages ? Does broker have a thread pool, from which threads are allocated to the process of message enqueuing ? I want to understand the threading model of this aspect? Thanks, Anuj -- Vie

CamelRoutesBroker plugin won't shut down routes on reload

AMQ version 5.11 on RHLinux version 6.6. I am running in a test environment, and there are no other users on my system. I am using the Camel Routes Broker plugin in my AMQ broker in order to route messages between topics: I have a separate routes.xml file which loads up my route just

How do i connect a glassfish server 4 to an external activeMQ 5.11?

I need help with this topic please -- View this message in context: http://activemq.2283324.n4.nabble.com/How-do-i-connect-a-glassfish-server-4-to-an-external-activeMQ-5-11-tp4696156.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Queue Purge not working in 5.8

We are using AMQ 5.8 and we have queues that are created for one time use and then never used again - over a period of months these stale queues build up to a large number and clutter the Web GUI making it hard to manage. I have added the Destination Purge settings to the activemq.xml: ht

Re: Does JMS priority work with “small" maxPageSize ?

Was it implemented for topic subscriptions because there is only one consumer so you don't have to worry about synchronization between threads? Is that the primary thing that will make implementing this for queues hard? If so, why is it only available for durable subscriptions but not non-durable

Re: KahabDB compatibility issue between ActiveMQ 5.10 and ActiveMQ 5.11

I just looked through all the 5.11.x JIRA issues and don't see any that describe this change outright nor any that I would have expected to require making the change. Abhi, did you find the code change that causes the change you describe? If so, can you see if the commit includes the number of th

Re: Does JMS priority work with “small" maxPageSize ?

that is true, the dispatch goes through the cursors in batches once memory (or the cursor cache) is exhausted. For durable subs, there is the ability to bypass the paged in messages, see: https://github.com/apache/activemq/blob/165959e25007271f8cdfdcf72641b9a92483ef40/activemq-unit-tests/src/test/j