You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by "Kartick Suriamoorthy @ zp" <ka...@zooplus.com> on 2009/08/25 12:56:34 UTC
Sender/Receiver hangs after 4776 messages ....
I am just trying out ActiveMQ and I seem to be running into a problem.
I have not changed the initial configuration in any way. I just bring up the
ActiveMQ server, create a queue called ks-test-queue via the admin page.
Then I create a jndi.properties file (attached), and start a sender and a
receiver. The sender spawns 10 threads and each thread send 1000 messages to
the ks-test-queue. The receiver just listens on the ks-test-queue.
After the sender sends 4776 messages, no more messages are being sent or
received. I see no exceptions anywhere (in the console of ActiveMQ or in my
sender/receiver programs).
Any idea what is going on ?
http://www.nabble.com/file/p25132261/jndi.properties jndi.properties
http://www.nabble.com/file/p25132261/MessageSender.java MessageSender.java
http://www.nabble.com/file/p25132261/MessageReceiver.java
MessageReceiver.java
--
View this message in context: http://www.nabble.com/Sender-Receiver-hangs-after-4776-messages-....-tp25132261p25132261.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Sender/Receiver hangs after 4776 messages ....
Posted by Gary Tully <ga...@gmail.com>.
You have a transacted session in your consumer but you do not commit any
transactions so the broker is holding messages in memory pending a commit
and the memory limits are preventing further message production because of
producer flow controll.
You should see some relevant details in the jmx console.
To resolve, change:
QueueSession session = qconn.createQueueSession(true, 0);
to:
QueueSession session = qconn.createQueueSession(false, AUTO_ACKNOWLEDGE);
2009/8/25 Kartick Suriamoorthy @ zp <ka...@zooplus.com>
>
>
> I am just trying out ActiveMQ and I seem to be running into a problem.
>
> I have not changed the initial configuration in any way. I just bring up
> the
> ActiveMQ server, create a queue called ks-test-queue via the admin page.
>
> Then I create a jndi.properties file (attached), and start a sender and a
> receiver. The sender spawns 10 threads and each thread send 1000 messages
> to
> the ks-test-queue. The receiver just listens on the ks-test-queue.
>
> After the sender sends 4776 messages, no more messages are being sent or
> received. I see no exceptions anywhere (in the console of ActiveMQ or in my
> sender/receiver programs).
>
> Any idea what is going on ?
>
> http://www.nabble.com/file/p25132261/jndi.properties jndi.properties
>
> http://www.nabble.com/file/p25132261/MessageSender.java MessageSender.java
>
> http://www.nabble.com/file/p25132261/MessageReceiver.java
> MessageReceiver.java
> --
> View this message in context:
> http://www.nabble.com/Sender-Receiver-hangs-after-4776-messages-....-tp25132261p25132261.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
Re: Sender/Receiver hangs after 4776 messages ....
Posted by "Kartick Suriamoorthy @ zp" <ka...@zooplus.com>.
By the way, all the programs are running on the same local desktop (windows
XP, Professional Version 2002, Service Pack 3).
There is no abnormal memory of CPU usage in the Task Manager (it is beefy
desktop - Dual Core Pentium CPU, 2.5GHz, 3.5 GB of RAM).
Kartick Suriamoorthy @ zp wrote:
>
>
> I am just trying out ActiveMQ and I seem to be running into a problem.
>
> I have not changed the initial configuration in any way. I just bring up
> the ActiveMQ server, create a queue called ks-test-queue via the admin
> page.
>
> Then I create a jndi.properties file (attached), and start a sender and a
> receiver. The sender spawns 10 threads and each thread send 1000 messages
> to the ks-test-queue. The receiver just listens on the ks-test-queue.
>
> After the sender sends 4776 messages, no more messages are being sent or
> received. I see no exceptions anywhere (in the console of ActiveMQ or in
> my sender/receiver programs).
>
> Any idea what is going on ?
>
> http://www.nabble.com/file/p25132261/jndi.properties jndi.properties
>
> http://www.nabble.com/file/p25132261/MessageSender.java
> MessageSender.java
>
> http://www.nabble.com/file/p25132261/MessageReceiver.java
> MessageReceiver.java
>
--
View this message in context: http://www.nabble.com/Sender-Receiver-hangs-after-4776-messages-....-tp25132261p25132299.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.