[hornetq-commits] JBoss hornetq SVN: r10929 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/remoting/impl/invm.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-07-06 00:55:20 -0400 (Wed, 06 Jul 2011)
New Revision: 10929

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/remoting/impl/invm/InVMConnection.java
Log:
tweak

Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/remoting/impl/invm/InVMConnection.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/remoting/impl/invm/InVMConnection.java	2011-07-06 04:50:47 UTC (rev 10928)
+++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/remoting/impl/invm/InVMConnection.java	2011-07-06 04:55:20 UTC (rev 10929)
@@ -147,31 +147,32 @@
                }
             }
          });
+         
+         if (flush)
+         {
+            final CountDownLatch latch = new CountDownLatch(1);
+            executor.execute(new Runnable(){
+               public void run()
+               {
+                  latch.countDown();
+               }
+            });
+            
+            try
+            {
+               latch.await(10, TimeUnit.SECONDS);
+            }
+            catch (InterruptedException e)
+            {
+               log.debug(e.getMessage(), e);
+            }
+         }
       }
       catch (RejectedExecutionException e)
       {
          // Ignore - this can happen if server/client is shutdown and another request comes in
       }
       
-      if (flush)
-      {
-         final CountDownLatch latch = new CountDownLatch(1);
-         executor.execute(new Runnable(){
-            public void run()
-            {
-               latch.countDown();
-            }
-         });
-         
-         try
-         {
-            latch.await(10, TimeUnit.SECONDS);
-         }
-         catch (InterruptedException e)
-         {
-            log.debug(e.getMessage(), e);
-         }
-      }
    }
 
    public String getRemoteAddress()