Hi, sorry for the spam:
I have the following configuration
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" producerFlowControl="false">
<pendingDurableSubscriberPolicy>
<fileDurableSubscriberCursor/>
</pendingDurableSubscriberPolicy>
<pendingSubscriberPolicy>
<fileCursor />
</pendingSubscriberPolicy>
</policyEntry>
<policyEntry queue=">" producerFlowControl="false">
<pendingQueuePolicy>
<fileQueueCursor/>
</pendingQueuePolicy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
and memory usage like this:
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage limit="500 mb"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="1 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="100 mb"/>
</tempUsage>
</systemUsage>
</systemUsage>
Im configuring a persistent producer and a durable consumer. When I shut
down the consumer, broker starts to give me this messages:
2012-01-27 12:26:11,575 | DEBUG | default:memory:topic://T_SYSTEM3:memory:
usage change from: 33% of available memory, to: 34% of available memory |
org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///127.0.0.1:56722
2012-01-27 12:26:11,576 | DEBUG | default:memory: usage change from: 33% of
available memory, to: 34% of available memory |
org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///127.0.0.1:56722
2012-01-27 12:26:12,587 | DEBUG | default:memory:topic://T_SYSTEM3:memory:
usage change from: 34% of available memory, to: 35% of available memory |
org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///127.0.0.1:56722
2012-01-27 12:26:12,587 | DEBUG | default:memory: usage change from: 34% of
available memory, to: 35% of available memory |
org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///127.0.0.1:56722
When the memory usage grows to 100% and outOfMemory of java heap is
thrown, Are the cursors working well? did I miss some configuration? Im
using activemq 5.5.1.
regards
2012/1/27 Oscar Pernas <os...@pernas.es>
> I dont know why, but If I set fileCursor and to a topic my broker starts
> to consume memory untill hungs with java heap size limit... fileCursor
> should not avoid this?
>
>
> 2012/1/27 Oscar Pernas <os...@pernas.es>
>
>> Hi all,
>>
>> Im trying to optimize and hardening activemq and I have some question:
>>
>> - If I set producerFlowControl to false, should I need to set the memory
>> limit? I dont know if I set the memory limit, firstly all messages goes to
>> memory until is full, and after that goes to disk?
>> - Do I need to set <pendingSubscriberPolicy> and
>> <pendingDurableSubscriberPolicy> if I have durable and no durable consumers?
>> - If Im using file based cursors for queues and topics, should I have to
>> define the usage memory? I should define the storeUsage for the file based
>> cursors, but the tempStorage and memoryUsage would be needed?
>>
>>
>>
>> Thanks in advance!
>>
>> --
>> Óscar Pernas Plaza.
>>
>
>
>
> --
> Óscar Pernas Plaza.
>
--
Óscar Pernas Plaza.
