Author: clebert.suconic(a)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) {