activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mittler, Nathan" <>
Subject RE: LoadTesting ActiveMQ for Synchronous Calls. (Consumer disappears)
Date Tue, 29 Apr 2008 00:48:24 GMT
Can you verify that things work fine when using a Java client to receive
the messages?  If so, it sounds like a C++ client bug - I recommend
raising a JIRA issue and attaching a sample program if you can cook one
up quickly.


> -----Original Message-----
> From: rahuljoshi80 []
> Sent: Monday, April 28, 2008 5:14 PM
> To:
> Subject: LoadTesting ActiveMQ for Synchronous Calls. (Consumer
> I have a java Test Client that is using the javax.jms.TopicRequestor
> send
> a request on a topic. Below is a snippet of code of how the
> call is made.
> javax.jms.TopicRequestor requestor = new
> javax.jms.TopicRequestor(aSession,
> aJmsTopic);
>         javax.jms.Message response = requestor.request(msg);
>         javax.jms.TextMessage textMessage = (javax.jms.TextMessage)
> response;
> As Seen above i am trying to make a synchronous call.
> I have a C++ program on the other side of the Broker that is listening
> the "aJMSTopic" using a message Listener. When the C++ program
receives a
> msg, it takes this message and stores a <messageID,ReplyTodestination>
> pair
> in a local map. When it is time to publish a reply , the C++ program
> where to send the reply as it has the ReplyToDestination stored in a
> Thus the java client gets the appropriate response.
> The most interesting thing here is that this mechanism works perfectly
> until
> i put it under some load. Lets say that the java test client just
> making these requests. After some time, the messageListener on the C++
> side
> will stop receiving messages from the java test client.
> There are no exceptions that occur in the activemq log files. Also,
> the
> messageListener stop receiving messages at that point i also noticed
> jconsole shows me that the consumer count for that particular topic is
0 !
> So obviously the message listener is not listening to the message
> published
> by the java test client. Why would this happen?
> Has anyone tried to do a similar kind of load test...thats is
> calling between a java and a C++ program on either side of the broker?
> Any insight will be appreciated. Please help...we really need to get
> pattern to work.  I have tried several things including performing a
> consumer.receive (timeout) on the c++ side as opposed to using a
> messageListener.
> Thanking you Sincerely
> Rahul
> --
> View this message in context:
> for-Synchronous-Calls.-%28Consumer-disappears%29-
> tp16948105s2354p16948105.html
> Sent from the ActiveMQ - User mailing list archive at

View raw message