[hornetq-commits] JBoss hornetq SVN: r9637 - branches/Branch_2_1/examples/soak/tx-restarts/src/org/hornetq/jms/example.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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 ---------------------------------------------