Yep, have tried various cursors including this but still the same occasional slow sending. Sometimes it is seconds long. Very odd.
For completeness sakes here is the start options ACTIVEMQ_OPTS="-Xmx1024M -Xss128k -Dorg.apache.activemq.UseDedicatedTaskRunner=false -verbosegc -XX:+PrintGCDetails -XX:+PrintGCDateStamps " and below is the config. So despite various configurations, flow control on, off, etc still can't work out why seeing occasional pauses. Have tried with logging on / off. No GC debugging, etc. Doesn't appear to be coincidental with any GC activity and if reproducable when both MQ and java app on same machine as well as more traditionally on separate machine. What does the pagedin messages refer to? Thanks for any help :-) (and happy holidays!) Adrian :working: <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://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/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:${activemq.base}/conf/credentials.properties</value> </property> </bean> <broker xmlns="http://activemq.apache.org/schema/core"; brokerName="localhost" dataDirectory="${activemq.base}/data" advisorySupport="false" > <destinationPolicy> <policyMap> <policyEntries> <policyEntry queue=">" memoryLimit="500mb" producerFlowControl="false" > <dispatchPolicy> <strictOrderDispatchPolicy /> </dispatchPolicy> <deadLetterStrategy> <individualDeadLetterStrategy queuePrefix="Test.DLQ."/> </deadLetterStrategy> <pendingQueuePolicy> <vmQueueCursor /> </pendingQueuePolicy> </policyEntry> <policyEntry topic=">" memoryLimit="500mb" producerFlowControl="false" /> </policyEntries> </policyMap> </destinationPolicy> <managementContext> <managementContext createConnector="false"/> </managementContext> <networkConnectors> <networkConnector name="default-nc" uri="multicast://default"/> </networkConnectors> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage limit="500 mb"/> </memoryUsage> <storeUsage> <storeUsage limit="1 gb" name="foo"/> </storeUsage> <tempUsage> <tempUsage limit="400 mb"/> </tempUsage> </systemUsage> </systemUsage> <transportConnectors> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" discoveryUri="multicast://default"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/> </transportConnectors> <persistenceAdapter> <kahaPersistenceAdapter directory="activemq-data" maxDataFileLength="33554432"/> </persistenceAdapter> </broker> <jetty xmlns="http://mortbay.com/schemas/jetty/1.0";> <connectors> <nioConnector port="8161"/> </connectors> <handlers> <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/> <webAppContext contextPath="/console" resourceBase="${activemq.base}/webapps/console" logUrlOnStart="true" /> </handlers> </jetty> </beans> -- View this message in context: http://old.nabble.com/Slow-sending-of-messages-tp26849964p26891081.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
