;
>>>>>>> logUrlOnStart="true"/>
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>> rajdavies wrote:
>>>>>>>>
>>>>>&
hats
why I
was interested to find out if you'd discovered some kind of
fresh
angle.
Regards,
Maarten
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27623064.html
Sent from the ActiveMQ - User mailing list archive at
Nabble.com.
Rob Davies
ht
ne by message listeners
>>>>>>> that
>>>>>>> all have
>>>>>>> their own connection. So everything should have its own
>>>>>>> connection,
>>>>>>> let
>>>>>>> alone sessio
s the topic, and their dequeue/enqueue stats
flatline
as well, even though flow control shouldn't apply to them.
Thats
why I
was interested to find out if you'd discovered some kind of
fresh
angle.
Regards,
Maarten
--
View this message in context:
http://old.nabble.com/Slow-sen
Adrian A wrote:
>>>>>>
>>>>>> you are running separate sessions for each of those dequeue/enqueue
>>>>>> stats?
>>>>>>
>>>>>> in my flow control tests even when one particular session was hung
>>>>
;>>> broker and
>>>>> GC / disk checkpointing occurred that it got really bad.
>>>>>
>>>>> have you turned on debugging as that although verbose is a wealth
>>>>> of
>>>>> information!
>>>>>
>>
x27;t apply to them. Thats
why I
was interested to find out if you'd discovered some kind of fresh
angle.
Regards,
Maarten
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27623064.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
gt;>
>>>> Maarten_D wrote:
>>>>>
>>>>> Hi Adrian, thanks for your response.
>>>>>
>>>>> I'm currently running tests where I have a very fast producer and a
>>>>> relatively slow consumer. The producer pub
raph in visualvm completely levels off. This is more
>>>> or less
>>>> expected, as I've turned on producerFlowControl for topics.
>>>> However, the
>>>> entire broker stalls. I have several queues that are filled and
>>>> emptie
pply to them. Thats
why I
was interested to find out if you'd discovered some kind of fresh
angle.
Regards,
Maarten
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27623064.html
Sent from the ActiveMQ - User mailing list archive at
e
>> as well, even though flow control shouldn't apply to them. Thats why I
>> was interested to find out if you'd discovered some kind of fresh angle.
>> Regards,
>> Maarten
>>
>
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27623064.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
d discovered some kind of fresh angle.
> Regards,
> Maarten
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27612368.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
message.setLong("test4",);
>>> message.setLong("test5",);
>>>
>>> by 10 to 20 times worse.
>>>
>>>
>>> Adrian A wrote:
>>>>
>>>> long start = System.currentTimeMillis();
>>>> producer.send(message);
>>>> long stop = System.currentTimeMillis();
>>>>
>>>
>>>
>>
>>
>
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27612143.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>> by 10 to 20 times worse.
>>
>>
>> Adrian A wrote:
>>>
>>> long start = System.currentTimeMillis();
>>> producer.send(message);
>>> long stop = System.currentTimeMillis();
>>>
>>
>>
>
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p27611873.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
t; message.setLong("test4",);
> message.setLong("test5",);
>
> by 10 to 20 times worse.
>
>
> Adrian A wrote:
>>
>> long start = System.currentTimeMillis();
>> producer.send(message);
>> long stop = Sys
System.currentTimeMillis();
> producer.send(message);
> long stop = System.currentTimeMillis();
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p26916149.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ry.setAlwaysSessionAsync(true);
>>>factory.setProducerWindowSize(1024*1024);
>>> connection = (ActiveMQConnection) factory.createConnection();
>>>
>>>connection.start();
>>>
>>> Session
>>> new ActiveMQQueueS
;>ActiveMQPrefetchPolicy pfp = new ActiveMQPrefetchPolicy();
>>pfp.setAll(5000);
>>factory.setPrefetchPolicy(pfp);
>>factory.setAlwaysSessionAsync(true);
>>factory.setProducerWindowSize(1024*1024);
>> connection
SessionAsync(true);
>>factory.setProducerWindowSize(1024*1024);
>>connection = (ActiveMQConnection) factory.createConnection();
>>
>>connection.start();
>>
>> Session
>> new ActiveMQQueueSession((ActiveMQSession)
>> connection.createSessi
ssion
> 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.
teConnection();
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-tp26849964p268911
http://mortbay.com/schemas/jetty/1.0";>
--
View this me
gMessageCursor that will maintain all references
> > in
> > memory. See the end of
> > http://activemq.apache.org/message-cursors.html for details.
> >
> >
>
> --
> View this message in context:
> http://old.nabble.com/Slow-sending-of-messages-tp26849964p26873612.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
>>
>>
>>
>>> discoveryUri="multicast://default"/>
>>
>>
>>
>>
>>
>>http://mortbay.com/schemas/jetty/1.0";>
>>
>>
also there is a VMPendingMessageCursor that will maintain all references
> in
> memory. See the end of
> http://activemq.apache.org/message-cursors.html for details.
>
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p26873612.html
1.0";>
>
>
>
>
>
> resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/>
> resourceBase="${activemq.base}/webapps/console" logUrlOnStart="true" />
>
;
> Hi,
>
> Can you post your broker's cfg file?
>
> Also, what is the average size of the non-persistent messages that you're
> pushing through the broker?
>
> Joe
> http://www.ttmsolutions.com
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p26867191.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
http://issues.apache.org/activemq/browse/AMQ-2413
> issues?
>
> Any other ideas? I have fast consumers and producers but I just can't find
> any reference to what the pagedinmessages are referring to.
>
> Any help would be really appreciated as this is totally confusing me :-(
>
> many thanks
>
> Adrian
>
>
>
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p26865030.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
lly confusing me :-(
many thanks
Adrian
--
View this message in context:
http://old.nabble.com/Slow-sending-of-messages-tp26849964p26849964.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
29 matches
Mail list logo
