Oscar-
What is your Java heap size?
On 1/27/12 5:29 AM, Oscar Pernas wrote:
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.
