[hornetq-commits] JBoss hornetq SVN: r9637 - branches/Branch_2_1/examples/soak/tx-restarts/src/org/hornetq/jms/example.
Author: clebert.suconic(a)jboss.com
Date: 2010-09-02 23:36:41 -0400 (Thu, 02 Sep 2010)
New Revision: 9637
Modified:
branches/Branch_2_1/examples/soak/tx-restarts/src/org/hornetq/jms/example/Receiver.java
Log:
tweak
Modified:
branches/Branch_2_1/examples/soak/tx-restarts/src/org/hornetq/jms/example/Receiver.java
===================================================================
---
branches/Branch_2_1/examples/soak/tx-restarts/src/org/hornetq/jms/example/Receiver.java 2010-09-03
03:15:25 UTC (rev 9636)
+++
branches/Branch_2_1/examples/soak/tx-restarts/src/org/hornetq/jms/example/Receiver.java 2010-09-03
03:36:41 UTC (rev 9637)
@@ -38,6 +38,8 @@
private final Semaphore sem = new Semaphore(0);
+ private final Semaphore max = new Semaphore(10000);
+
private final String queueJNDI;
protected volatile long msgs = 0;
@@ -75,6 +77,7 @@
{
break;
}
+ max.release();
Message msg = cons.receive(5000);
if (msg == null)
{
@@ -148,6 +151,14 @@
public void messageProduced(int pendingMsgs2)
{
sem.release(pendingMsgs2);
+ try
+ {
+ max.acquire(pendingMsgs2);
+ }
+ catch (InterruptedException e)
+ {
+ e.printStackTrace();
+ }
}
// Package protected ---------------------------------------------