| Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr on MAIN | |||
| SubscriptionRegistry.java | +2 | -4 | 1.2 -> 1.3 |
tidied up the code
servicemix/base/src/main/java/org/servicemix/jbi/nmr
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);
}
}
