activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adrian A <adri...@acta.co.uk>
Subject Re: Slow sending of messages
Date Tue, 22 Dec 2009 16:52:49 GMT

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.


Mime
View raw message