Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr on MAIN
SubscriptionRegistry.java+2-41.2 -> 1.3
tidied up the code

servicemix/base/src/main/java/org/servicemix/jbi/nmr
SubscriptionRegistry.java 1.2 -> 1.3
diff -u -r1.2 -r1.3
--- SubscriptionRegistry.java	20 Sep 2005 16:53:19 -0000	1.2
+++ SubscriptionRegistry.java	20 Sep 2005 16:54:26 -0000	1.3
@@ -17,9 +17,10 @@
  **/
 package org.servicemix.jbi.nmr;
 
+import EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap;
+
 import org.servicemix.jbi.container.SubscriptionSpec;
 import org.servicemix.jbi.messaging.MessageExchangeImpl;
-import org.servicemix.jbi.nmr.flow.Flow;
 import org.servicemix.jbi.servicedesc.ServiceEndpointImpl;
 
 import javax.jbi.JBIException;
@@ -27,8 +28,6 @@
 import java.util.Iterator;
 import java.util.Map;
 
-import EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap;
-
 /**
  * Maintains a registry of the applicable subscriptions currently active for the
  * current components
@@ -47,7 +46,6 @@
 
             if (subscription.matches(exchange)) {
                 ServiceEndpointImpl endpoint = (ServiceEndpointImpl) entry.getValue();
-                ;
                 subscriptionManager.dispatchToSubscriber(exchange, endpoint);
             }
         }
CVSspam 0.2.8



Reply via email to