Re: ActiveMQ - Unable to limit temp store

>
> Hello,
>
> after several days of testing, i am facing the following issue : I am
> unable
> to limit the physical space of temp storage used by AMQ, and temp_store is
> growing ever and ever...
>
> ===========================
> = Scenario :
> ===========================
> - One JVM, handling several producers, spamming the broker.
> - One JVM, embedding the broker, with several consumers.
> - All message are as DeliveryMode.NON_PERSISTENT
>
> ===========================
> = Configuration (resumed)
> ===========================
> - AMQ.maxFileLength=67108864
> - <memoryUsage limit="128mb"/>
> - <storeUsage limit="88mb" store="#store" />
> - <tempUsage limit="160mb"/>
> - <policyEntry queue=">" producerFlowControl="false" memoryLimit="64mb"/>
>
> This should means, based on my understanding :
> - The temp store is limited to 88mb
> - Each temp file is 64 mb, so i should have 1 (or 2) temp files maximum
>
> 1) ISSUE1 : After flooding the broker, i have massive files into temp
> directory, enforcing activemq configuration...
> I have followed several post recommandations, including
> "
> http://open-source-adventures.blogspot.com/2009/01/limiting-disk-store-usage-with-active.html
> ",
> without any success.
>
> 2) ISSUE2 : The maxFileLegth has no effect, since i have massive flood of
> 32
> MB "data-TopicSubscription-XXX" files inside "tmp_storage" folder.
>
> Someone may have a solution here (i hope...). Thanks by advance!
> Regards.
>
> ===========================
> = JMX on start
> ===========================
> - Broker.Memory = 134217728
> - Broker.StoreLimit = 92274688
> - Broker.TempLimit = 167772160
> - Queue.MemoryLimit = 67108864
>
> ===========================
> = JMX while running
> ===========================
> - Broker.MemoryPercentUsage = 320 (???)
> - Broker.StorePercentUsage = 0 (logic, i am not using persistent senders)
> - Broker.TempPercentUsage = 0 (not logic : i have plenty of temp store
> files)
> - Queue.MemoryPercentUsage = 0 (???)
> - Queue.CursorMemoryUsage=435215400
> - Queue.CursorPercentUser=324 (???)
>
> ===========================
> = ActiveMQ full configuration :
> ===========================
> <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-2.0.xsd
>  http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd
>  http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd">
>
>        <!-- Allows us to use system properties as variables in this
> configuration
> file -->
>        <bean
>
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>                <property name="locations">
>
> <value>file:C:\xxx\Experimental\maven.1236678842549\src\test\resources\jms2\activemq.properties</value>
>                </property>
>        </bean>
>
>        <!-- The store, declared as bean due to
> http://issues.apache.org/activemq/browse/AMQ-2064 -->
>        <bean id="store"
> class="org.apache.activemq.store.amq.AMQPersistenceAdapter">
>                <!-- Data directory -->
>                <property name="directory" value="${activemq.base}/data"/>
>                <!-- 64 mb -->
>                <property name="maxFileLength" value="67108864"/>
>                <!-- References to files -->
>                <property name="persistentIndex" value="true"/>
>        </bean>
>
>
>        <!-- The broker -->
>        <broker xmlns="http://activemq.apache.org/schema/core"
> persistent="true"
> advisorySupport="false" useJmx="true" brokerName="LCH.TEST"
> monitorConnectionSplits="false"
> splitSystemUsageForProducersConsumers="false" start="false"
> persistenceAdapter="#store">
>
>                <!-- Destination specific policies using destination names
> or wildcards
> -->
>                <destinationPolicy>
>                        <policyMap>
>                                <policyEntries>
>                                        <!-- *** producerFlowControl=false
> -->
>                                        <!-- When this is added, all your
> queues will start persisting their
> messages to the disk. -->
>                                        <!-- Freeing your RAM to consume
> more messages w/o any slowdowns. -->
>                                        <!-- *** memoryLimit : Per queue
> memory limit -->
>                                        <policyEntry queue=">"
> producerFlowControl="false" memoryLimit="64mb"/>
>                                </policyEntries>
>                        </policyMap>
>                </destinationPolicy>
>
>                <!-- The transport connectors ActiveMQ will listen to -->
>                <transportConnectors>
>                        <transportConnector name="LCH"
> uri="nio://MIYOPC65:61616"/>
>                </transportConnectors>
>
>                <!-- Use the following to configure how ActiveMQ is exposed
> in JMX -->
>                <managementContext>
>                        <managementContext createConnector="true"/>
>                </managementContext>
>
>                <!-- The maximum about of space the broker will use before
> slowing down
> producers -->
>                <!-- sendFailIfNoSpace : If no more is available, send
> client a JMS
> exception -->
>                <systemUsage>
>                        <systemUsage sendFailIfNoSpace="true">
>                                <!-- Memory usage max -->
>                                <memoryUsage>
>                                        <!-- Sets the memory limit in bytes
> (broker global). Setting the limit
> in bytes will set the usagePortion to 0  -->
>                                        <memoryUsage limit="128mb"/>
>                                </memoryUsage>
>
>                                <!-- Storage is used for those messages that
> have been sent PERSISTENT
> -->
>                                <storeUsage>
>                                        <!-- Sets the memory limit in bytes
> (broker global). Setting the limit
> in bytes will set the usagePortion to 0  -->
>                                        <storeUsage limit="88mb"
> store="#store" />
>                                </storeUsage>
>
>                                <!-- Temporary storage is used for spooling
> out messages that have been
> sent NON_PERSISTENT -->
>                                <tempUsage>
>                                        <!-- Sets the memory limit in bytes
> (broker global). Setting the limit
> in bytes will set the usagePortion to 0  -->
>                                        <tempUsage limit="160mb"/>
>                                </tempUsage>
>                        </systemUsage>
>                </systemUsage>
>        </broker>
>
>        <!--
>        ** Lets configure some Camel endpoints
>        **
>        ** http://activemq.apache.org/camel/components.html
>        -->
>
>        <!-- configure the camel activemq component to use the current
> broker -->
>        <bean id="activemq"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
>                <property name="connectionFactory">
>                        <bean
> class="org.apache.activemq.ActiveMQConnectionFactory">
>                                <property name="brokerURL"
> value="vm://localhost?create=false&waitForStart=10000"/>
>                                <property name="userName"
> value="${activemq.username}"/>
>                                <property name="password"
> value="${activemq.password}"/>
>                        </bean>
>                </property>
>        </bean>
> </beans>
>
> --
> View this message in context:
> http://www.nabble.com/ActiveMQ---Unable-to-limit-temp-store-tp24309792p24309792.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>