Hi there
have you considered to set a time to live on your messages.
If you send messages NON_PERSISTENT that should work.
If you send PERSISTENT messages, you should probably configure the
DiscardingDLQBrokerPlugin as well.
Best regards
Andreas
On Mar 24, 2009, at 10:16 PM, ashoknan wrote:
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.
---
Mit freundlichen Grüssen - Kind Regards
Andreas Gies
Principal Consultant
Open Source Center of Competence
Progress Software GmbH
Agrippinawerft 26
50678 Köln
E-Mail ag...@progress.com
Direct Line +49 (0)9953 980349
Mobile +49 (0)170 5759611
Skype +44 (0)20 3239 2922
Skype +353 (0)1 443 4971
Skype +1 (0)781 262 0168
http://www.progress.com
http://fusesource.com
http://open-source-adventures.blogspot.com
-------------------------------------------------------
Progress Software GmbH
Sitz der Gesellschaft: Agrippinawerft 26, 50678 Koeln;
Niederlassung: Fuerstenrieder Str. 279, 81377 Muenchen
Amtsgericht Koeln, HRB 15620;
Geschaeftsfuehrung: David Ireland
-------------------------------------------------------
