[hornetq-commits] JBoss hornetq SVN: r12254 - in trunk/hornetq-core/src/main/java/org/hornetq: core/client/impl and 2 other directories.

[do-not-reply at jboss.org]

Author: borges
Date: 2012-03-07 07:47:50 -0500 (Wed, 07 Mar 2012)
New Revision: 12254

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
Log:
Make some classes final

Modified: trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java	2012-03-06 22:56:22 UTC (rev 12253)
+++ trunk/hornetq-core/src/main/java/org/hornetq/api/core/client/HornetQClient.java	2012-03-07 12:47:50 UTC (rev 12254)
@@ -26,7 +26,7 @@
  *
  * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
  */
-public class HornetQClient
+public final class HornetQClient
 {
    public static final String DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME = RoundRobinConnectionLoadBalancingPolicy.class.getCanonicalName();
 

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java	2012-03-06 22:56:22 UTC (rev 12253)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/Topology.java	2012-03-07 12:47:50 UTC (rev 12254)
@@ -32,7 +32,7 @@
  * @author Clebert Suconic
  *         Created Aug 16, 2010
  */
-public class Topology implements Serializable
+public final class Topology implements Serializable
 {
 
    private static final long serialVersionUID = -9037171688692471371L;

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java	2012-03-06 22:56:22 UTC (rev 12253)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java	2012-03-07 12:47:50 UTC (rev 12254)
@@ -24,28 +24,28 @@
  *
  * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
  */
-public class ClusterConnectionConfiguration implements Serializable
+public final class ClusterConnectionConfiguration implements Serializable
 {
    private static final long serialVersionUID = 8948303813427795935L;
 
    private final String name;
 
    private final String address;
-   
+
    private final String connectorName;
 
    private final long clientFailureCheckPeriod;
-   
+
    private final long connectionTTL;
-   
+
    private final long retryInterval;
-   
+
    private final double retryIntervalMultiplier;
-   
+
    private final long maxRetryInterval;
-   
+
    private final int reconnectAttempts;
-   
+
    private final long callTimeout;
 
    private final long callFailoverTimeout;
@@ -63,9 +63,9 @@
    private final int confirmationWindowSize;
 
    private final boolean allowDirectConnectionsOnly;
-   
+
    private final int minLargeMessageSize;
-   
+
    public ClusterConnectionConfiguration(final String name,
                                          final String address,
                                          final String connectorName,
@@ -138,7 +138,7 @@
       this.minLargeMessageSize = minLargeMessageSize;
    }
 
-   
+
    public ClusterConnectionConfiguration(final String name,
                                          final String address,
                                          final String connectorName,
@@ -217,7 +217,7 @@
    {
       return address;
    }
-   
+
    /**
     * @return the clientFailureCheckPeriod
     */
@@ -257,7 +257,7 @@
    {
       return reconnectAttempts;
    }
-   
+
    public long getCallTimeout()
    {
       return callTimeout;
@@ -321,6 +321,6 @@
    {
       return minLargeMessageSize;
    }
-   
-   
+
+
 }

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2012-03-06 22:56:22 UTC (rev 12253)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2012-03-07 12:47:50 UTC (rev 12254)
@@ -66,17 +66,17 @@
 import org.hornetq.utils.UUID;
 
 /**
- * 
+ *
  * A ClusterConnectionImpl
  *
  * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
  * @author Clebert Suconic
- * 
+ *
  * Created 21 Jan 2009 14:43:05
  *
  *
  */
-public class ClusterConnectionImpl implements ClusterConnection, AfterConnectInternalListener
+public final class ClusterConnectionImpl implements ClusterConnection, AfterConnectInternalListener
 {
    private static final Logger log = Logger.getLogger(ClusterConnectionImpl.class);
 
@@ -145,7 +145,7 @@
    private final Set<TransportConfiguration> allowableConnections = new HashSet<TransportConfiguration>();
 
    private final ClusterManagerInternal manager;
-   
+
    private final int minLargeMessageSize;
 
 
@@ -247,7 +247,7 @@
       this.callTimeout = callTimeout;
 
       this.callFailoverTimeout = callFailoverTimeout;
-      
+
       this.minLargeMessageSize = minLargeMessageSize;
 
       clusterConnector = new StaticClusterConnector(tcConfigs);
@@ -324,7 +324,7 @@
       this.retryIntervalMultiplier = retryIntervalMultiplier;
 
       this.maxRetryInterval = maxRetryInterval;
-      
+
       this.minLargeMessageSize = minLargeMessageSize;
 
       this.reconnectAttempts = reconnectAttempts;
@@ -512,7 +512,7 @@
                   {
                      announceBackup();
                   }
-               
+
                }, retryInterval, TimeUnit.MILLISECONDS);
             }
          }
@@ -699,7 +699,7 @@
          serverLocator.setBlockOnDurableSend(!useDuplicateDetection);
          serverLocator.setBlockOnNonDurableSend(!useDuplicateDetection);
          serverLocator.setCallTimeout(callTimeout);
-         
+
          // No producer flow control on the bridges, as we don't want to lock the queues
          serverLocator.setProducerWindowSize(-1);