[hornetq-commits] JBoss hornetq SVN: r10929 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/remoting/impl/invm.
Author: clebert.suconic(a)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()