NoSuchElementException

All, Has anybody else seen this exception from ActiveMQ before? We are running version 5.5.1. Exception in thread "BrokerService[XYZ] Task-195864037" java.util.NoSuchElementException at java.util.LinkedList.remove(LinkedList.java:788) at java.util.LinkedList.removeFirst(Linke

Pending message limit strategy and memory limits

All, I have a situation where I'd like to discard non-persistent messages if necessary. What I'd like to do is discard the oldest messages first for slow consumers but only if needed. So far I've; - turned off flow control - set the memory limit in my default policy entry - added a messa

Usage Manager memory limit reached

We just ran into the warning below indicating that we've exceeded the memory available on a Topic. WARNING: Async error occurred: javax.jms.ResourceAllocationException: Usage Manager memory limit reached. Stopping producer (ID:hoeplx3764-34102-1345832926291-0:2:2:1) to prevent flooding topic:/

occasional ConcurrentModificationException when creating a queue consumer

All, Can anybody give me some ideas about why I get the ConcurrentModificationExcpetion below occasionally. We are running with version 5.5. The code that generates this exception is; LOG.fine("Create response queue") ; _session2 = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE) ;

alternatives to request response pattern

Are there any recommendations or techniques for how to avoid having to use a request/response pattern? I'm using the technique described here http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html. I'm primarily doing this to get some basic configuration information

Re: how to set pendingSubscriberPolicy for an embedded broker

org/apache/activemq/broker/region/policy/PolicyEntry.html) > > Hope this helps, > > -Marcelo > > > > > On May 19, 2011, at 12:17 PM, Steve Angelovich wrote: > >> I have an embedded broker and I want to set specify which cursor to use >> and some of th

how to set pendingSubscriberPolicy for an embedded broker

I have an embedded broker and I want to set specify which cursor to use and some of the attributes. When using the activemq.xml file I'm specifying something like; Can somebody point me to an example or the right place in the javadocs so that I can specify this information pro

killing the broker also kills clients on the local machine

Does anybody know why or how this happens. If both the message broker and one of the clients are running on the same machine when the broker is killed the client will also terminate. If the client is running on a different host the client behaves as expected by reconnecting as soon as the broke

Adding a C client

All, We have a legacy application that we need to add into our messaging environment. Currently we are using version 4.1.1 and all the clients are java. We've looked at the activemq-cpp and done some tests. The small amount of testing that we've done so far this works well, but our legacy

JMS client timeout or inactivity error

All, Any recommendations on how to track down a client connectivity issue. Occasionally I get the error below on some of my clients. Of course I only see this when there is a lot of activity. I've found some references to connectionTimeout, soTimeout and maxInactivityDuration but not much inform

Client blocking during service interruption

I've just started using ActiveMQ and am running into a problem with a service interruption test case. I'm currently running the message service as an embedded application and no persistence. The client uses failover so that I can reconnect to the messaging service if there is an interruption. Th