activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matt Pavlovich <mattr...@gmail.com>
Subject Re: producer flow control questions
Date Fri, 27 Jan 2012 15:15:00 GMT
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<oscar@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<oscar@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.
>>
>
>

Mime
View raw message