activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ashoknan <ashokkumar.sanka...@chase.com>
Subject How to discard messages for the non-durable queue
Date Tue, 24 Mar 2009 21:16:38 GMT

I am using ActiveMQ 5.1..wanted to know how to discard messages for the
non-durable queue.
Trying to deal with slow consumer problem...Wanted to avoid Broker reaching
100%. When ever broker reaches 100% on the memory, everything stops.

Will discarding will avoid broker reaching 100% on the memory.

When the broker reaches 100% this what i see in the threaddump

"Thread-4" prio=6 tid=0x3e20d400 nid=0x128c waiting on condition
[0x3ec0f000..0x3ec0fa94]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0b278ff8> (a
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
	at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1925)
	at
java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:317)
	at
org.apache.activemq.transport.FutureResponse.getResult(FutureResponse.java:40)
	at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:80)
	at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1195)
	at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1644)
	- locked <0x06be2688> (a java.lang.Object)
	at
org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:227)
	at org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:74)
	- locked <0x06be1008> (a org.apache.activemq.ActiveMQMessageProducer)
	at org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:59)
	at org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:534)
	at org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:511)
	at org.springframework.jms.core.JmsTemplate$2.doInJms(JmsTemplate.java:477)
	at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:428)
	at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:475)
	at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:467)
	at jmsexample.ExampleProducer.sendMessage(ExampleProducer.java:21)
	at jmsexample.Bootstrap$1.run(Bootstrap.java:49)
	at java.lang.Thread.run(Thread.java:619)






-- 
View this message in context: http://www.nabble.com/How-to-discard-messages-for-the-non-durable-queue-tp22689964p22689964.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message