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

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@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@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@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);