Re: Producer Performance

Session is single-threaded. If you don't have many connections and they are relatively long-lived, there's no big problem in having multiple connections from a single process. Note from the JMS 1.1 standard section 4.3 "Connection" (my bolding): "Due to the authentication and communication setu

Re: activemq how to dispatch message

Sorry I'm not in a position to review your code. But you could start with the examples in the Example directory and work up from there - the examples function correctly. Good instructions on how to run them are at http://activemq.apache.org/examples.html - Michael Hayes B.Sc. (NUI), M.Sc.

Re: Consumer performance

I would fiddle with the prefetch limits to begin with. To see if it makes a difference, you can increase the queue prefetch limit for your consumers as much as you can (subject to heapspace constraints on the consumers). Estimate the extra heapspace needed to hold the prefetched messages in the co

Re: jdbc Master looses DB connection, Slave won't acquire the lock

that is expected. it is up to the db server to notice the dropped tcp connection and clean it up. there is some good information at: https://issues.apache.org/jira/browse/AMQ-3654 I have been working on a variation of the default database locker that uses a time based lease rather than an open tra

why doesn't xinclude work in activemq's activemq.xml???

When you use xi:include in activemq.xml, it doesn't work. Just has an XML parse error, cannot find element include. How can I use xi:include in activemq? -- View this message in context: http://activemq.2283324.n4.nabble.com/why-doesn-t-xinclude-work-in-activemq-s-activemq-xml-tp4653273.html

Re: Sugestions how to listen on several thousand topics with spring?

Rather than looking at consuming from hundreds of topics individually, I would approach the problem in terms of namespaces. If all of these topics are named consistently, you could set up a smaller set of listeners against a wildcard topic subscription (http://activemq.apache.org/wildcards.html) pe

Consumer performance

I am trying to understand the performance profile of ActuveMQ. I have a queue with 1,000,000 messages. Running a single consumer process (C++ using CMS MessageListener, auto acknowledge) I get consume 700-800 msg per second. Run a second and they both run at ~500m/s. The performance degrades for ea

jdbc Master looses DB connection, Slave won't acquire the lock

With pure jdbc Master/Slave, when Master fails to connect to database (caused by networking issue), Slave cannot acquire the lock. Is this what one should expect? AMQ 5.6, Postrgres 9.1, Ubuntu. Each broker and DB are on separate hosts. Thank you. - Serguei -- View this message in context: http

AMQ 5.6 NIO Transport & Interceptors Problem

Hello all, I am having a problem, we have an interceptor that adds a custom security layer to AMQ that we've been using an 5.4 and 5.5, when we use it in 5.6 its OK, but when I change the transport from tcp to nio, we no longer get callbacks, and the connections lockup and don't complete... Is th

Need to include webconsole-embedded.xml password encryption to the activemq encrypted passwords documentation

The documentation here: http://activemq.apache.org/encrypted-passwords.html Does not say anything about how to get the $ACTIVEMQ_HOME/webapps/admin/WEB-INF/webconsole-embedded.xml to start using the credentials-enc.properties file, like activemq.xml switched to. Steps: Edit - *$ACTIVEMQ_HOME/web

Is there a windows service option for Apollo MQ?

-- Garry Watkins Application Developer Arnold & Porter LLP 555 Twelfth Street, NW Washington, DC 20004-1206 Telephone: +1 202.942.6215 garry.watk...@aporter.com www.arnoldporter.com _ U.S. Treasur

Re: Sugestions how to listen on several thousand topics with spring?

Deadlock: BrokerService[test] Task-1 is waiting to lock java.lang.Object@95cc0b which is held by NettyWorker-thread-1 NettyWorker-thread-1 is waiting to lock java.lang.Object@126c1c8 which is held by BrokerService[test] Task-1 Thread stacks BrokerService[test] Task-1 [BLOCKED; waiting to lo

Re: Sugestions how to listen on several thousand topics with spring?

I finally moved away from the idea to use the session threads. Now my listener schedules the handling of each message into a thread pool (see SimpleMessageListenerContainer.setThreadExecutor) In addition i use a different connection uri with new parameters: alwaysSessionAsync=false makes sure tha

Problem in asynchronous dispatch of message

Good morning. I'm using ActiveMQ 5.6.0 under OSGi environment. I'm running an application with several producers and consumers. Sometimes, one of my producers is freezed while sending a message (please find attached a print screen of the stacktrace for this call). Is there a way to preven