activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From SuoNayi <suonayi2...@163.com>
Subject Re:Re: Trying to set up non-persistant messaging...
Date Tue, 23 Apr 2013 05:22:23 GMT
Hi Christian, does it make sense the VMCursor does not respect memory usage limit?




At 2013-04-23 07:03:12,"Christian Posta" <christian.posta@gmail.com> wrote:
>What are you using for prefetch on your consumers? And how many consumers?
>The queue subscription will use a VM cursor. If your subscription gets
>dispatched a number of messages that would put it over the memory limit,
>then that is your issue. If you can put together a test case, I can take a
>look deeper.
>
>
>On Mon, Apr 22, 2013 at 2:18 PM, SledgeHammer <grosin@firstam.com> wrote:
>
>> Here you go. I am only use Queues at this time.
>>
>>
>>
>> <beans
>>   xmlns="http://www.springframework.org/schema/beans"
>>   xmlns:amq="http://activemq.apache.org/schema/core"
>>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>>   xsi:schemaLocation="http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans.xsd
>>   http://activemq.apache.org/schema/core
>> http://activemq.apache.org/schema/core/activemq-core.xsd">
>>
>>
>>     <bean
>>
>> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>>         <property name="locations">
>>             <value>file:${activemq.conf}/credentials.properties</value>
>>         </property>
>>     </bean>
>>
>>
>>     <broker xmlns="http://activemq.apache.org/schema/core"
>> brokerName="localhost" dataDirectory="${activemq.data}" persistent="false">
>>
>>
>>
>>         <destinationPolicy>
>>             <policyMap>
>>               <policyEntries>
>>                 <policyEntry topic=">" producerFlowControl="true">
>>
>>                   <pendingMessageLimitStrategy>
>>                     <constantPendingMessageLimitStrategy limit="1000"/>
>>                   </pendingMessageLimitStrategy>
>>                 </policyEntry>
>>                 <policyEntry queue=">" producerFlowControl="false">
>>
>>                   <pendingQueuePolicy>
>>                     <fileQueueCursor />
>>                   </pendingQueuePolicy>
>>
>>
>>                 </policyEntry>
>>               </policyEntries>
>>             </policyMap>
>>         </destinationPolicy>
>>
>>
>>
>>         <managementContext>
>>             <managementContext createConnector="false"/>
>>         </managementContext>
>>
>>
>>         <persistenceAdapter>
>>             <kahaDB directory="${activemq.data}/kahadb"/>
>>         </persistenceAdapter>
>>
>>
>>
>>           <systemUsage>
>>             <systemUsage>
>>                 <memoryUsage>
>>                     <memoryUsage limit="64 mb"/>
>>                 </memoryUsage>
>>                 <storeUsage>
>>                     <storeUsage limit="100 gb"/>
>>                 </storeUsage>
>>                 <tempUsage>
>>                     <tempUsage limit="50 gb"/>
>>                 </tempUsage>
>>             </systemUsage>
>>         </systemUsage>
>>
>>
>>         <transportConnectors>
>>
>>             <transportConnector name="openwire"
>> uri="tcp://
>> 0.0.0.0:25055?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600
>> "/>
>>             <transportConnector name="amqp"
>> uri="amqp://
>> 0.0.0.0:5672?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600
>> "/>
>>         </transportConnectors>
>>
>>
>>         <shutdownHooks>
>>             <bean xmlns="http://www.springframework.org/schema/beans"
>> class="org.apache.activemq.hooks.SpringContextHook" />
>>         </shutdownHooks>
>>
>>     </broker>
>>
>>
>>     <import resource="jetty.xml"/>
>>
>> </beans>
>>
>>
>>
>>
>> --
>> View this message in context:
>> http://activemq.2283324.n4.nabble.com/Trying-to-set-up-non-persistant-messaging-tp4666127p4666129.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>
>
>
>-- 
>*Christian Posta*
>http://www.christianposta.com/blog
>twitter: @christianposta

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