How does Producer flow control work with JDBC persitance?

I read below link about producer flow control but I am still confused about how it works when we have JDBC only persistance. http://activemq.apache.org/message-cursors.html I am noticing that ActiveMQ blocks even with JDBC only persistance but it doesn't make sense to me as to why it should bloc

Failover transport hangs on startup if it cannot connect to a broker

Hi all! The failover transport should return normally on connection.start() even if it cannot connect to a remote broker on startup, right? In all cases I am trying, it blocks on startup, preventing initialization of the rest of the ActiveMQ components. I have filed a Jira issue on this: AMQ-211

Re: Messages rollback

Thanks very much for AMQ CPP. Our legacy system using the stomp library from http://stomp.codehaus.org and write stomp frame to socket directly. The impls of commit and abort are "COMMIT" and "ABORT" in the stomp frame header. With regards to "ABORT", the message acknowledge are abort and M

Re: Memoryleak when consuming messages from KahaDBStore

Hello, I just tried something with the Netbeans memory profiler. My assumption is: If nothing hass been added to an application then after 2 full runs of the Garbace Collector the memory should be the same. In the past we have seen that memory was increasing while messages have been processed by

AMQ 4.1.2, FailoverTransport and Firewall

We have this configuration: - AMQ 4.1.2 - Client outside of a firewall. Uses FailoverTransport to connect to brokers. - Two brokers inside of firewall in master/slave configuration Problem: Upon startup, if the client attempts to connect to the slave broker instead of the master broker, the firew

sending a string to activeMQ is stomp usiong C++ and sockets

hello we are nitzan and tal, we are students at the universtiy for Computer Science we have a task to implement a simple chat room we need to use a stomp and ActiveMQ we started the activeMQ and now in our "testClient" class (in C++) we wrote the folowing line to the console CONNECT\nlogin:foo

Re: Bytesmessage and http transport

Hi, The max message size use can send over HTTP is limited by max POST size Jetty server will accept. I thinks it's 1MB by default, so it shouldn't cause the problem you're seeing. Can you reproduce the problem reliably (with the test case ideally) and file it as a Jira issue? Cheers -- Dejan Bos

Re: Messages rollback

Yes - it looks like there was a bug fixed in the transaction support [1] so you would need the 2.2 release [2] of the C++ API for the transacted session capabilities. [1] http://issues.apache.org/activemq/browse/AMQCPP-174 [2] http://activemq.apache.org/cms/activemq-cpp-22-release.html Regards /D

Re: Memoryleak when consuming messages from KahaDBStore

Btw: These are my JVM settings (1.6.0_10) # Java Additional Parameters # note that n is the parameter number starting from 1. wrapper.java.additional.1=-Dactivemq.home=%ACTIVEMQ_HOME% wrapper.java.additional.2=-Dactivemq.base=%ACTIVEMQ_BASE% wrapper.java.additional.3=-Dcom.sun.management.jmxremote

Memoryleak when consuming messages from KahaDBStore

Hello, I'm working with the lastest 5.3 trunk and using the new KahaDBStore. Last night I made a test: I have a queue that contained >30 Mio messages. I started 20 consumers to empty the queue. The consumers are running in their own VM. While retrieving messages from AMW the memory consumption of