activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1440116 - /activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Date Tue, 29 Jan 2013 20:46:49 GMT
Author: tabish
Date: Tue Jan 29 20:46:49 2013
New Revision: 1440116

URL: http://svn.apache.org/viewvc?rev=1440116&view=rev
Log:
remove unused imports and add override annotations.  Fix some spelling in the comments.

Modified:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java?rev=1440116&r1=1440115&r2=1440116&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
Tue Jan 29 20:46:49 2013
@@ -33,12 +33,12 @@ import java.util.concurrent.atomic.Atomi
 
 import javax.management.ObjectName;
 
+import org.apache.activemq.DestinationDoesNotExistException;
 import org.apache.activemq.Service;
 import org.apache.activemq.advisory.AdvisoryBroker;
 import org.apache.activemq.advisory.AdvisorySupport;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.BrokerServiceAware;
-import org.apache.activemq.DestinationDoesNotExistException;
 import org.apache.activemq.broker.ConnectionContext;
 import org.apache.activemq.broker.TransportConnection;
 import org.apache.activemq.broker.region.AbstractRegion;
@@ -81,7 +81,6 @@ import org.apache.activemq.transport.Fut
 import org.apache.activemq.transport.ResponseCallback;
 import org.apache.activemq.transport.Transport;
 import org.apache.activemq.transport.TransportDisposedIOException;
-import org.apache.activemq.transport.TransportFactory;
 import org.apache.activemq.transport.TransportFilter;
 import org.apache.activemq.transport.tcp.SslTransport;
 import org.apache.activemq.util.IdGenerator;
@@ -702,7 +701,7 @@ public abstract class DemandForwardingBr
                 LOG.trace(configuration.getBrokerName() + " bridging " + (destInfo.isAddOperation()
? "add" : "remove") + " destination on " + localBroker + " from " + remoteBrokerName + ",
destination: " + destInfo);
             }
             if (destInfo.isRemoveOperation()) {
-                // serialise with removeSub operations such that all removeSub advisories
are generated
+                // Serialize with removeSub operations such that all removeSub advisories
are generated
                 serialExecutor.execute(new Runnable() {
                     @Override
                     public void run() {
@@ -809,7 +808,7 @@ public abstract class DemandForwardingBr
             subscriptionMapByRemoteId.remove(sub.getRemoteInfo().getConsumerId());
 
             // continue removal in separate thread to free up this thread for outstanding
responses
-            // serialise with removeDestination operations so that removeSubs are serialised
with removeDestinations
+            // Serialize with removeDestination operations so that removeSubs are serialised
with removeDestinations
             // such that all removeSub advisories are generated
             serialExecutor.execute(new Runnable() {
                 @Override



Mime
View raw message