Re: How to handle fast producer when JMS timeout happens?

2. less "pre-fetch" from consumer by setting for example tcp://localhost:61616?jms.prefetchPolicy.all=1 is there anything I miss? Gary Tully wrote: > > have u read through: > http://activemq.apache.org/slow-consumer-handling.html > > On 21 May 2010 14:25, easyl wrote:

How to handle fast producer when JMS timeout happens?

Geronimo 2.2 / AMQ 5.3 I have the following scenario producerA --send-->(Queue)--> consumerB The prodcerA sends JMS message continuously to consumerB, while consumerB can consume message slower than that producerA produces. (consumerB processes the message and has database operations.) To t

Re: ActiveMQConnection leaks memory by caching ActiveMQTempQueue objects

erent application on different JVM and let them send/reply messages to/from each other, therefore I use TCP transport. Can I use VM Transport across JVM, did I misunderstand the meaning of transport? Ivan Pechorin wrote: > > Hello, > > 2010/4/29 easyl : >> AMQ 5.3 in Geronim

ActiveMQConnection leaks memory by caching ActiveMQTempQueue objects

AMQ 5.3 in Geronimo 2.2 I found ActiveMQConnection always hold the ActiveMQTempQueue and should lead to memory leak, especially using massive send/reply through temp queues. I create a ticket here https://issues.apache.org/activemq/browse/AMQ-2716 -- View this message in context: http://old.n

finding workaround to solve memory leak problem when creating large numbers of TemporaryQueues (Log4J related)

I am using embedded AMQ 4.1.2 (in geronimo 2.1.4) and find there is a memory problem similar to this: https://issues.apache.org/activemq/browse/AMQ-1681 I run a system (64bit, 3G mem) after 8 hours, about 100 temp queue was created for send/reply. I can find 400~500 MB (and counting) for Log4

Embedded AMQ on many App Server on the same host

I am going to run more than one Geronimo with embedded AMQ4 on the same server machine. Each Geronimo will host different service (EAR with message driven bean) which communicates with each other by exchanging messages. How should I setup the embedded AMQ? Can I still use VM? since the Geronimo

Re: sudden NullPointerException from ActiveMQSessionExecutor.wakeup

Setting jms.asyncDispatch=true would ease the problem.. http://activemq.apache.org/consumer-dispatch-async.html easyl wrote: > > AMQ 4.1.2 embedded in Geronimo 2.1.3 > > setup in deployment plan with > > vm://localhost?async=true&jms.asyncDispatch=false&j

sudden NullPointerException from ActiveMQSessionExecutor.wakeup

AMQ 4.1.2 embedded in Geronimo 2.1.3 setup in deployment plan with vm://localhost?async=true&jms.asyncDispatch=false&jms.copyMessageOnSend=false&jms.watchTopicAdvisories=false there are 6 different Queues listened by MDBs which may send messages to each other (almost w

Re: RejectedExecutionException and Message stalled in AMQ 4

solution found. The AMQ4 is run embedded in geronimo2.1. And the default thread pool has only size from 30 for the whole system. so.increase the ConnectorThreadPool prevent such RejectedExecutionException http://cwiki.apache.org/GMOxDOC22/monitoring-thread-pools.html -- View this message i

RejectedExecutionException and Message stalled in AMQ 4

I am using Geronimo 2.1 with AMQ4. Sometime I got RejectedExecutionException from ActiveMQ TCP Transport, and the AMQ won't continue to process the messages stalled in queues. I don't know if my application lead the problem, I see no Exception from my application server. On http://activemq.apache

[WARN] TransportConnection Failed to remove producer

I have an application run on geronimo(websphere community edition) with ActiveMQ 4.1.2 # org.apache.activemq/activemq-core/4.1.2/jar # org.apache.geronimo.configs/activemq-broker/2.1.4/car # org.apache.geronimo.configs/activemq-ra/2.1.4/car Messages are exchanged between MDB with following code