activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ashoknan <ashokkumar.sanka...@chase.com>
Subject Re: How to discard messages for the non-durable queue
Date Wed, 25 Mar 2009 20:25:40 GMT

Yes i tried that.

But it's going to ActiveMQ DLQ. How the messages from DLQ will be removed.
Do i have to write something to clear the DLQ.

Another thing i noticed is..when i set prefetch as 10 broker was able to
dispatch 2Million messages after that the broker memory % used reaching 100
then it hangs...when i set prefetch to 100 then i dont have any problem..it
was able to process 11M messages with out any issues. I am not sure why this
is the case.


		

		
		
			
				
					" producerFlowControl="true">
					
				
			
		

		
		
			
				
					
				
			
		

		
			
		
	






Andreas Gies-3 wrote:
> 
> 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      	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
> -------------------------------------------------------
> 
> 

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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message