activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marcin Giedz <marcin.gi...@arise.pl>
Subject Re: AMQ 5.5 remove temporary destination
Date Wed, 28 Mar 2012 16:31:27 GMT

here is the link to screenshot for such active-dead temp-queue 

http://www.screencast.com/t/ev5CosagTcqw 


Thx 
M. 

----- Oryginalna wiadomość -----

Od: "Marcin Giedz" <marcin.giedz@arise.pl> 
Do: users@activemq.apache.org 
Wysłane: środa, 28 marzec 2012 18:27:32 
Temat: Re: AMQ 5.5 remove temporary destination 



Hi, 


Once again full config: 



<broker xmlns="http://activemq.apache.org/schema/core" brokerName="waw1-amq1" dataDirectory="${activemq.base}/data"
useJmx="true" advisorySupport="true" peschedulePeriodForDestinationPurge="10000" allowTempAutoCreationOnSend="true">



<!-- 
Use VM cursor 
For more information, see: 
http://activemq.apache.org/message-cursors.html 
--> 
<destinationPolicy> 
<policyMap> 
<policyEntries> 
<policyEntry topic=">" producerFlowControl="true" memoryLimit="100mb"> 
<pendingSubscriberPolicy> 
<fileCursor/> 
</pendingSubscriberPolicy> 
</policyEntry> 
<policyEntry queue=">" producerFlowControl="true" memoryLimit="100mb"> 
<pendingQueuePolicy> 
<vmQueueCursor/> 
</pendingQueuePolicy> 
</policyEntry> 


<policyEntry tempTopic="true" producerFlowControl="true" memoryLimit="100mb"> 
<pendingSubscriberPolicy> 
<fileCursor/> 
</pendingSubscriberPolicy> 
</policyEntry> 
<policyEntry tempQueue="true" producerFlowControl="true" memoryLimit="100mb" gcInactiveDestinations="true"
inactiveTimoutBeforeG 
<pendingQueuePolicy> 
<vmQueueCursor/> 
</pendingQueuePolicy> 
</policyEntry> 


</policyEntries> 
</policyMap> 
</destinationPolicy> 




<managementContext> 
<managementContext createConnector="true"/> 
</managementContext> 


<networkConnectors> 
<networkConnector uri="static:(tcp://172.16.36.7:61616)"> 
<dynamicallyIncludedDestinations/> 
<excludedDestinations> 
<queue physicalName="pl.arise.cms.to.pats"/> 
<queue physicalName="pl.arise.cmsproxy"/> 
<queue physicalName="pl.arise.dictionaryservice"/> 
<queue physicalName="pl.arise.omsauthorization"/> 
<queue physicalName="pl.arise.omsinstruments"/> 
<queue physicalName="pl.arise.omsorderbook"/> 
<queue physicalName="pl.arise.omsserver"/> 
<queue physicalName="pl.arise.omsfixserver"/> 
<queue physicalName="pl.arise.omstradeserver"/> 
<queue physicalName="pl.arise.permissionsservice"/> 
<queue physicalName="pl.arise.settingsservice"/> 
<queue physicalName="pl.arise.sirorderbookserver"/> 
<topic physicalName="BSE"/> 
<topic physicalName="SIR"/> 
<topic physicalName="pl.arise.statusserver"/> 
</excludedDestinations> 
</networkConnector> 
</networkConnectors> 


<!-- 
Use KahaDB for persistence 
Tune it a bit so we minimize IO operations 
For more information, see: 
http://activemq.apache.org/kahadb.html 
--> 
<persistenceAdapter> 
<kahaDB directory="${activemq.base}/data/kahadb" enableJournalDiskSyncs="false" indexWriteBatchSize="10000"
indexCacheSize="1000"/> 
</persistenceAdapter> 




<systemUsage> 
<systemUsage> 
<memoryUsage> 
<memoryUsage limit="24 gb"/> 
</memoryUsage> 
<storeUsage> 
<storeUsage limit="10 gb" name="store"/> 
</storeUsage> 
<tempUsage> 
<tempUsage limit="10 gb"/> 
</tempUsage> 
</systemUsage> 
</systemUsage> 




<!-- 
Use TCP transport 
For more information, see: 
http://activemq.apache.org/configuring-transports.html 
--> 
<transportConnectors> 
<transportConnector name="openwire" uri="nio://0.0.0.0:61616?keepAlive=true"/> 
</transportConnectors> 


</broker> 

Results: 


some temp-queues are removed some not. I don;t know if maillist can accept attachment but
I'm sending jconsole example for temp-queues which are not removed ... these temp queues have
ConsumerCOunt=0 and EnqueueCount value is increasing so more and more memory is taken. Such
dead-active temp-queues stay when application which creates it hangs or a network problem
is simulated. In such cases they are not removed by the system but should be removed by AMQ
after inactivity time reaches its level, right? 


I guess AMQ still things that this particular temp-queue is active as producer creates knew
messages on it. In such case is there any way to push AMQ to remove such temp-queue? 


Thx 
M. 


----- Oryginalna wiadomość -----

Od: "Marcin Giedz" <marcin.giedz@arise.pl> 
Do: users@activemq.apache.org 
Wysłane: poniedziałek, 26 marzec 2012 14:56:58 
Temat: Re: AMQ 5.5 remove temporary destination 

Thx a lot... I will check this and send you a results ;) 


Thx 
Marcin 

----- Oryginalna wiadomość ----- 

Od: "Dejan Bosanac" <dejan@nighttale.net> 
Do: users@activemq.apache.org 
Wysłane: poniedziałek, 26 marzec 2012 14:54:02 
Temat: Re: AMQ 5.5 remove temporary destination 

Yes, it should be there since 5.4.0. It checks if destination is empty and 
doesn't have any producers/consumers for a certain time. 


Regards 
-- 
Dejan Bosanac 
Senior Software Engineer | FuseSource Corp. 
dejanb@fusesource.com | fusesource.com 
skype: dejan.bosanac | twitter: @dejanb 
blog: http://www.nighttale.net 
ActiveMQ in Action: http://www.manning.com/snyder/ 



On Mon, Mar 26, 2012 at 12:55 PM, Marcin Giedz <marcin.giedz@arise.pl>wrote: 

> Hi Dejan, 
> 
> 
> Thx for you update... I assume 5.5.1-fuse contains this fix? 
> 
> 
> and: how AMQ decides which temp-queue is about to be removed - what 
> condition pls? 
> 
> 
> Thx 
> Marcin 
> 
> ----- Oryginalna wiadomość ----- 
> 
> Od: "Dejan Bosanac" <dejan@nighttale.net> 
> Do: users@activemq.apache.org 
> Wysłane: poniedziałek, 26 marzec 2012 11:31:37 
> Temat: Re: AMQ 5.5 remove temporary destination 
> 
> Try adding <broker .... allowTempAutoCreationOnSend="true"> 
> 
> so that gc include temporary destinations as well. 
> 
> 
> Regards 
> -- 
> Dejan Bosanac 
> Senior Software Engineer | FuseSource Corp. 
> dejanb@fusesource.com | fusesource.com 
> skype: dejan.bosanac | twitter: @dejanb 
> blog: http://www.nighttale.net 
> ActiveMQ in Action: http://www.manning.com/snyder/ 
> 
> 
> 
> On Fri, Mar 23, 2012 at 3:13 PM, Marcin Giedz <marcin.giedz@arise.pl> 
> wrote: 
> 
> > 
> > Hi, 
> > 
> > 
> > Our temp queue policy is set as follows: 
> > 
> > 
> > <policyEntry tempQueue="true" producerFlowControl="true" 
> > memoryLimit="100mb" gcInactiveDestinations="true" 
> > inactiveTimoutBeforeGC="30000"> 
> > <pendingQueuePolicy> 
> > <vmQueueCursor/> 
> > </pendingQueuePolicy> 
> > </policyEntry> 
> > 
> > 
> > question: what conditions are taken into account in case of "remove daed 
> > temp queues"? - number of consumers, producers, etc? 
> > 
> > 
> > With such configuration I still can see live temp-queues with 
> > ConsumerCount=0 - I thought that this could trigger AMQ to remove such 
> > queue but it doesn't. Did I miss something in configuration? 
> > 
> > 
> > Thx 
> > Marcin 
> 
> 
> 
> 
> 



-- 


Pozdrawiam 
Marcin Giedz 
Wiceprezes Zarządu 

ARISE Sp. z o.o. 
mob. +48 502 537 157 
mail: marcin.giedz@arise.pl 

ul. Waliców 11 
00-851 Warszawa 
tel./fax +48 (22) 583 93 40 
http: www.arise.pl 

ARISE Sp. z o.o. z siedzibą w Warszawie, ul. Al. Solidarności 117, 00-140 Warszawa, zarejestrowana
przez Sąd Rejonowy dla m. st. Warszawy w Warszawie XII Wydział Gospodarczy Krajowego Rejestru
Sądowego pod nr KRS 0000316860; REGON 141595449; NIP 527-259-06-10; z pokrytym w całości
kapitałem zakładowym wynoszącym 50,000.00 zł. 





-- 


Pozdrawiam 
Marcin Giedz 
Wiceprezes Zarządu 

ARISE Sp. z o.o. 
mob. +48 502 537 157 
mail: marcin.giedz@arise.pl 

ul. Waliców 11 
00-851 Warszawa 
tel./fax +48 (22) 583 93 40 
http: www.arise.pl 

ARISE Sp. z o.o. z siedzibą w Warszawie, ul. Al. Solidarności 117, 00-140 Warszawa, zarejestrowana
przez Sąd Rejonowy dla m. st. Warszawy w Warszawie XII Wydział Gospodarczy Krajowego Rejestru
Sądowego pod nr KRS 0000316860; REGON 141595449; NIP 527-259-06-10; z pokrytym w całości
kapitałem zakładowym wynoszącym 50,000.00 zł. 





-- 


Pozdrawiam 
Marcin Giedz 
Wiceprezes Zarządu 

ARISE Sp. z o.o. 
mob. +48 502 537 157 
mail: marcin.giedz@arise.pl 

ul. Waliców 11 
00-851 Warszawa 
tel./fax +48 (22) 583 93 40 
http: www.arise.pl 

ARISE Sp. z o.o. z siedzibą w Warszawie, ul. Al. Solidarności 117, 00-140 Warszawa, zarejestrowana
przez Sąd Rejonowy dla m. st. Warszawy w Warszawie XII Wydział Gospodarczy Krajowego Rejestru
Sądowego pod nr KRS 0000316860; REGON 141595449; NIP 527-259-06-10; z pokrytym w całości
kapitałem zakładowym wynoszącym 50,000.00 zł. 



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