[hornetq-commits] JBoss hornetq SVN: r11138 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-08-05 09:41:29 -0400 (Fri, 05 Aug 2011)
New Revision: 11138

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
Log:
Fixing confirmation window size

Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2011-08-05 13:10:52 UTC (rev 11137)
+++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2011-08-05 13:41:29 UTC (rev 11138)
@@ -105,6 +105,8 @@
    private final boolean useDuplicateDetection;
 
    private final boolean routeWhenNoConsumers;
+   
+   private final int confirmationWindowSize;
 
    private final Map<String, MessageFlowRecord> records = new ConcurrentHashMap<String, MessageFlowRecord>();
 
@@ -190,6 +192,8 @@
       this.useDuplicateDetection = useDuplicateDetection;
 
       this.routeWhenNoConsumers = routeWhenNoConsumers;
+      
+      this.confirmationWindowSize = confirmationWindowSize;
 
       this.executorFactory = executorFactory;
 
@@ -288,6 +292,8 @@
 
       this.routeWhenNoConsumers = routeWhenNoConsumers;
 
+      this.confirmationWindowSize = confirmationWindowSize;
+
       this.executorFactory = executorFactory;
 
       this.executor = executorFactory.getExecutor();
@@ -463,12 +469,16 @@
          serverLocator.setClientFailureCheckPeriod(clientFailureCheckPeriod);
          serverLocator.setConnectionTTL(connectionTTL);
 
-         if (serverLocator.getConfirmationWindowSize() < 0)
+         if (confirmationWindowSize < 0)
          {
             // We can't have confirmationSize = -1 on the cluster Bridge
             // Otherwise we won't have confirmation working
             serverLocator.setConfirmationWindowSize(0);
          }
+         else
+         {
+            serverLocator.setConfirmationWindowSize(confirmationWindowSize);
+         }
 
          if (!useDuplicateDetection)
          {