Hi Christian, does it make sense the VMCursor does not respect memory usage limit?
At 2013-04-23 07:03:12,"Christian Posta" <christian.po...@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 <gro...@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&wireformat.maxFrameSize=104857600 >> "/> >> <transportConnector name="amqp" >> uri="amqp:// >> 0.0.0.0:5672?maximumConnections=1000&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
