activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: Slow sending of messages
Date Wed, 23 Dec 2009 12:47:05 GMT
What are your consumers doing? What does jconsole say about the queue
depth/memory as the test runs?

This still sounds like flow control, you have
factory.setProducerWindowSize(1024*1024); which configures a producer window
which will cause the producer to block if it is full due to slow consumers.

possibly try using the sample producer/consumer tools that comes with the
examples[1] or look at the source of those producers/consumers to see if you
can generate something reproducible.

One other consideration for steady a enqueue rate is the store. You will get
near linear performance with KahaDB but with the AMQ store, index resizing
will occasionally cause a blip.

Happy Christmas!

[1] http://activemq.apache.org/examples.html

2009/12/22 Adrian A <adriana@acta.co.uk>

>
> Oh, and this is the java for creating connection
> url =
>
> failover:(tcp://mq:61616?wireFormat.cacheEnabled=false&wireFormat.tightEncodingEnabled=false&wireFormat.maxInactivityDuration=0&keepAlive=true)?maxReconnectAttempts=100
>
>  factory = new ActiveMQConnectionFactory(getProperties.getMQURL());
>        factory.setDispatchAsync(false);
>        factory.setUseAsyncSend(true);
>        factory.setOptimizeAcknowledge(true);//if true this sends acks in
> batches   (50% of the pre fetch size)
>        factory.setWatchTopicAdvisories(false);
>        factory.setCopyMessageOnSend(false);
>        ActiveMQPrefetchPolicy pfp = new ActiveMQPrefetchPolicy();
>        pfp.setAll(5000);
>        factory.setPrefetchPolicy(pfp);
>        factory.setAlwaysSessionAsync(true);
>        factory.setProducerWindowSize(1024*1024);
>        connection = (ActiveMQConnection) factory.createConnection();
>
>        connection.start();
>
> Session
> new ActiveMQQueueSession((ActiveMQSession) connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE));
> or
> connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>
>
> --
> View this message in context:
> http://old.nabble.com/Slow-sending-of-messages-tp26849964p26891119.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>


-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

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