[hornetq-commits] JBoss hornetq SVN: r11674 - branches/Branch_2_2_AS7/src/main/org/hornetq/core/config.

do-not-reply at jboss.org do-not-reply at jboss.org
Tue Nov 8 13:45:20 EST 2011


Author: clebert.suconic at jboss.com
Date: 2011-11-08 13:45:20 -0500 (Tue, 08 Nov 2011)
New Revision: 11674

Modified:
   branches/Branch_2_2_AS7/src/main/org/hornetq/core/config/BridgeConfiguration.java
Log:
Adding a constructor for backward compatibility on the API

Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/config/BridgeConfiguration.java
===================================================================
--- branches/Branch_2_2_AS7/src/main/org/hornetq/core/config/BridgeConfiguration.java	2011-11-08 16:33:21 UTC (rev 11673)
+++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/config/BridgeConfiguration.java	2011-11-08 18:45:20 UTC (rev 11674)
@@ -16,6 +16,8 @@
 import java.io.Serializable;
 import java.util.List;
 
+import org.hornetq.api.core.client.HornetQClient;
+
 /**
  * A BridgeConfiguration
  *
@@ -40,7 +42,7 @@
    private List<String> staticConnectors;
 
    private String discoveryGroupName;
-   
+
    private boolean ha;
 
    private String transformerClassName;
@@ -56,17 +58,55 @@
    private int confirmationWindowSize;
 
    private final long clientFailureCheckPeriod;
-   
+
    private String user;
-   
+
    private String password;
 
    private final long connectionTTL;
-   
+
    private final long maxRetryInterval;
-   
+
    private final int minLargeMessageSize;
 
+   /**
+    *  For backward compatibility on the API... no MinLareMessage on this constructor
+    */
+   public BridgeConfiguration(final String name,
+                              final String queueName,
+                              final String forwardingAddress,
+                              final String filterString,
+                              final String transformerClassName,
+                              final long retryInterval,
+                              final long maxRetryInterval,
+                              final double retryIntervalMultiplier,
+                              final int reconnectAttempts,
+                              final boolean useDuplicateDetection,
+                              final int confirmationWindowSize,
+                              final List<String> staticConnectors,
+                              final boolean ha,
+                              final String user,
+                              final String password)
+   {
+      this(name,
+           queueName,
+           forwardingAddress,
+           filterString,
+           transformerClassName,
+           HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
+           HornetQClient.DEFAULT_CLIENT_FAILURE_CHECK_PERIOD,
+           HornetQClient.DEFAULT_CONNECTION_TTL,
+           retryInterval,
+           maxRetryInterval,
+           retryIntervalMultiplier,
+           reconnectAttempts,
+           useDuplicateDetection,
+           confirmationWindowSize,
+           staticConnectors,
+           ha,
+           user,
+           password);
+   }
 
    public BridgeConfiguration(final String name,
                               final String queueName,
@@ -100,18 +140,57 @@
       this.confirmationWindowSize = confirmationWindowSize;
       this.clientFailureCheckPeriod = clientFailureCheckPeriod;
       this.staticConnectors = staticConnectors;
-      this. user = user;
+      this.user = user;
       this.password = password;
       this.connectionTTL = connectionTTL;
       this.maxRetryInterval = maxRetryInterval;
       discoveryGroupName = null;
    }
 
+   /**
+    *  For backward compatibility on the API... no MinLareMessage, checkPeriod and TTL  on this constructor
+    */
    public BridgeConfiguration(final String name,
                               final String queueName,
                               final String forwardingAddress,
                               final String filterString,
                               final String transformerClassName,
+                              final long retryInterval,
+                              final long maxRetryInterval,
+                              final double retryIntervalMultiplier,
+                              final int reconnectAttempts,
+                              final boolean useDuplicateDetection,
+                              final int confirmationWindowSize,
+                              final String discoveryGroupName,
+                              final boolean ha,
+                              final String user,
+                              final String password)
+   {
+      this(name,
+           queueName,
+           forwardingAddress,
+           filterString,
+           transformerClassName,
+           HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
+           HornetQClient.DEFAULT_CLIENT_FAILURE_CHECK_PERIOD,
+           HornetQClient.DEFAULT_CONNECTION_TTL,
+           retryInterval,
+           maxRetryInterval,
+           retryIntervalMultiplier,
+           reconnectAttempts,
+           useDuplicateDetection,
+           confirmationWindowSize,
+           discoveryGroupName,
+           ha,
+           user,
+           password);
+   }
+
+   public BridgeConfiguration(final String name,
+                              final String queueName,
+                              final String forwardingAddress,
+                              final String filterString,
+                              final String transformerClassName,
                               final int minLargeMessageSize,
                               final long clientFailureCheckPeriod,
                               final long connectionTTL,
@@ -197,7 +276,7 @@
    {
       return discoveryGroupName;
    }
-   
+
    public boolean isHA()
    {
       return ha;
@@ -288,7 +367,7 @@
    {
       this.discoveryGroupName = discoveryGroupName;
    }
-   
+
    /**
     * 
     * @param ha is the bridge supporting HA?



More information about the hornetq-commits mailing list