Rob Davies wrote:
Have you tried a 5.1 snapshot release ? We are constantly fixing issues
- some in this area
I have tried it. However, I have been unable to reliably reproduce the
problem in a test environment with 5.0 at this point so I cannot confirm
that this has been fixed in the 5.1 sn
@activemq.apache.org
Subject: Re: High message frequency causes ActiveMQ to freeze
On Jan 18, 2008, at 11:56 AM, <[EMAIL PROTECTED]> <[EMAIL PROTECTED] > wrote:
>
>> this is the latest 5.1 snapshot release ?
>
> Two days old. Should I get an update?
>
> Cheers,
> Jürgen.
H
;
>> Juergen.Schumacher wrote:
>>>
>>> Hi,
>>>
>>> do you really use a topic named FOO.* in your tests?
>>> You probably will have to adapt the topic="..." attribute
>>> of to your topic name - or replace it with
>>> que
]
Sent: Friday, January 18, 2008 2:15 PM
To: users@activemq.apache.org
Subject: Re: High message frequency causes ActiveMQ to freeze
We retry our testcase with the following lines
." attribute
> of to your topic name - or replace it with
> queue="..." if you are using a queue.
>
> Cheers,
> Jürgen
>
> -Original Message-
> From: Olivier Bigard [mailto:[EMAIL PROTECTED]
> Sent: Friday, January 18, 2008 2:15 PM
> To: users
On Jan 18, 2008, at 11:56 AM, <[EMAIL PROTECTED]> <[EMAIL PROTECTED]
> wrote:
this is the latest 5.1 snapshot release ?
Two days old. Should I get an update?
Cheers,
Jürgen.
Hi Jurgen,
it would help enourmously if you could raise an issue for this and
attach a test case - if possibl
e
the queue entirely. It seems like some kind of queue multiple
reader/writer
issue.
I wish I could offer more, but haven't had time to build a good test
case to
submit.
-Greg
--
View this message in context:
http://www.nabble.com/High-message-frequency-causes-ActiveMQ
he queue entirely. It seems like some kind of queue multiple reader/writer
issue.
I wish I could offer more, but haven't had time to build a good test case to
submit.
-Greg
--
View this message in context:
http://www.nabble.com/High-message-frequency-causes-ActiveMQ-to-freeze-tp14919292s2354p
AIL PROTECTED]
Sent: Friday, January 18, 2008 2:15 PM
To: users@activemq.apache.org
Subject: Re: High message frequency causes ActiveMQ to freeze
We retry our testcase with the following lines in "activemq.xml"
1");
>>>>consumer = sourceSession.createConsumer(source);
>>>>destination = destinationSession.createQueue("queue2");
>>>>producer = destinationSession.createProducer(destination);
>>>>producer.setDeliveryMode(DeliveryMode.PERSISTENT);
>>
> Btw - are you explicitly setting the SimpleDispatchPolicy for the Queue ?
Yes, I had this part in my activemq.xml:
Cheers,
Jürgen.
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
>>> }
>>>
>>> public void onMessage(Message message) {
>>>if (message instanceof TextMessage) {
>>> try {
>>> String id = ((TextMessage) message).getText();
>>>
String id = ((TextMessage) message).getText();
>>>LOG.info("Processing id = " + id);
>>>MapMessage map = destinationSession.createMapMessage();
>>> map.setString("id", id);
>>>map.setString("text", messa
Btw - are you explicitly setting the SimpleDispatchPolicy for the
Queue ?
On Jan 18, 2008, at 11:56 AM, <[EMAIL PROTECTED]> wrote:
this is the latest 5.1 snapshot release ?
Two days old. Should I get an update?
Cheers,
Jürgen.
related to the lockup.
Cheers,
Jürgen.
-Original Message-
From: Rob Davies [mailto:[EMAIL PROTECTED]
Sent: Friday, January 18, 2008 1:04 PM
To: users@activemq.apache.org
Subject: Re: High message frequency causes ActiveMQ to freeze
ooh - ok that's a bug - will fix today
On Jan 1
ooh - ok that's a bug - will fix today
On Jan 18, 2008, at 11:56 AM, <[EMAIL PROTECTED]> wrote:
this is the latest 5.1 snapshot release ?
Two days old. Should I get an update?
Cheers,
Jürgen.
> this is the latest 5.1 snapshot release ?
Two days old. Should I get an update?
Cheers,
Jürgen.
this is the latest 5.1 snapshot release ?
On Jan 18, 2008, at 11:47 AM, <[EMAIL PROTECTED]> wrote:
Hi again,
Seems that was a bit overhasty.
I'm still getting freezes, but much later in the test.
I also just did a test with non-transactional sessions and it locks up
even after the producers ha
Hi again,
Seems that was a bit overhasty.
I'm still getting freezes, but much later in the test.
I also just did a test with non-transactional sessions and it locks up
even after the producers have long stopped working. However, it seems to
be a bit different this time: The ActiveMQ server seems t
Hi,
> -Original Message-
> From: Rob Davies [mailto:[EMAIL PROTECTED]
> Sent: Friday, January 18, 2008 8:41 AM
>
> looks like you are creating transacted sessions and not calling commit
> - is that you mean to do ?
Where are commits missing? There is one commit after each message creati
Hi,
> -Original Message-
> From: Rob Davies [mailto:[EMAIL PROTECTED]
> Sent: Friday, January 18, 2008 8:28 AM
>
> It looks like you've hit flow control - you might want to disable it -
> see here: http://activemq.apache.org/producer-flow-control.html
Yes, that seems to be a part of th
ed " + producedCount + " messages.");
} catch (Exception ex) {
LOG.error("Error during processing", ex);
}
}
}
--
View this message in context:
http://www.nabble.com/High-message-frequency-causes-ActiveMQ-to-freeze-tp14919292s2354p14947393.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ession.commit();
producedCount++;
LOG.info("Produced " + producedCount + " messages.");
} catch (Exception ex) {
LOG.error("Error during processing", ex);
}
}
}
--
View this message in context:
http://www.nabble.com/High-message-frequency-causes-ActiveMQ-to-freeze-tp14919292s2354p14947393.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
wledge message");
> message.acknowledge();
> LOG.info("Commit source");
> sourceSession.commit();
> LOG.info("Commit destination");
> destinationSession.commit();
> producedCount++;
> LOG.info("Produced " + producedCount + " messages.");
> } catch (Exception ex) {
> LOG.error("Error during processing", ex);
> }
>
> }
> }
>
>
>
>
>
--
View this message in context:
http://www.nabble.com/High-message-frequency-causes-ActiveMQ-to-freeze-tp14919292s2354p14947393.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hello,
ok, attaching the source code file does apparently not work here.
So here are the relevant code parts from the producer and processor classes,
which create the connections to ActiveMQ and the messages.
Sorry for the trouble...
Regards,
Jürgen Schumacher
Procucer.java
Hello,
I am currently doing some stress tests with ActiveMQ 5. I have searched the
mailing list archive for similar reports, but they always seemed to resolve
to something like "it's fixed in the latest snapshot", which definitely did
not help in my case.
My test setup is as follows:
- 1 comp
26 matches
Mail list logo
