Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: local policy)
Message-Id: <2FDC8F1E-22E3-4BF5-8245-39BD79022492@progress.com>
From: Andreas Gies <agies@progress.com>
To: users@activemq.apache.org
In-Reply-To: <22689964.post@talk.nabble.com>
Content-Type: text/plain; charset=ISO-8859-1; format=flowed; delsp=yes
Content-Transfer-Encoding: quoted-printable
Mime-Version: 1.0 (Apple Message framework v930.3)
Subject: Re: How to discard messages for the non-durable queue
Date: Wed, 25 Mar 2009 13:51:28 +0100
References: <22689964.post@talk.nabble.com>

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 =20
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 =20=

> the
> non-durable queue.
> Trying to deal with slow consumer problem...Wanted to avoid Broker =20
> 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=3D6 tid=3D0x3e20d400 nid=3D0x128c 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=20
> $ConditionObject.await(AbstractQueuedSynchronizer.java:1925)
> 	at
> java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:=20=

> 317)
> 	at
> org=20
> .apache=20
> .activemq.transport.FutureResponse.getResult(FutureResponse.java:40)
> 	at
> org=20
> .apache=20
> .activemq=20
> .transport.ResponseCorrelator.request(ResponseCorrelator.java:80)
> 	at
> org=20
> .apache=20
> .activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:=20=

> 1195)
> 	at =
org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:=20
> 1644)
> 	- locked <0x06be2688> (a java.lang.Object)
> 	at
> org=20
> .apache=20
> .activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:=20=

> 227)
> 	at =
org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:=20
> 74)
> 	- locked <0x06be1008> (a =
org.apache.activemq.ActiveMQMessageProducer)
> 	at =
org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:=20
> 59)
> 	at =
org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:=20
> 534)
> 	at =
org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:=20
> 511)
> 	at org.springframework.jms.core.JmsTemplate=20
> $2.doInJms(JmsTemplate.java:477)
> 	at =20
> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:428)
> 	at =
org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:=20
> 475)
> 	at =
org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:=20
> 467)
> 	at =
jmsexample.ExampleProducer.sendMessage(ExampleProducer.java:21)
> 	at jmsexample.Bootstrap$1.run(Bootstrap.java:49)
> 	at java.lang.Thread.run(Thread.java:619)
>
>
>
>
>
>
> --=20
> View this message in context: =
http://www.nabble.com/How-to-discard-messages-for-the-non-durable-queue-tp=
22689964p22689964.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

---
Mit freundlichen Gr=FCssen - Kind Regards
Andreas Gies
Principal Consultant
Open Source Center of Competence

Progress Software GmbH
Agrippinawerft 26
50678 K=F6ln

E-Mail      	agies@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
-------------------------------------------------------