| Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr on MAIN | |||
| SubscriptionRegistry.java | +10 | -8 | 1.1 -> 1.2 |
tidied up the code
servicemix/base/src/main/java/org/servicemix/jbi/nmr
diff -u -r1.1 -r1.2 --- SubscriptionRegistry.java 20 Sep 2005 16:52:24 -0000 1.1 +++ SubscriptionRegistry.java 20 Sep 2005 16:53:19 -0000 1.2 @@ -30,7 +30,8 @@
import EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap; /**
- * Maintains a registry of the applicable subscriptions currently active for the current components
+ * Maintains a registry of the applicable subscriptions currently active for the + * current components
* * @version $Revision$ */
@@ -41,22 +42,23 @@
public void dispatchToSubscribers(MessageExchangeImpl exchange, SubscriptionManager subscriptionManager) throws JBIException {
for (Iterator iter = subscriptions.entrySet().iterator(); iter.hasNext();) {
Map.Entry entry = (Map.Entry) iter.next();
-
+
SubscriptionSpec subscription = (SubscriptionSpec) entry.getKey();
-
+
if (subscription.matches(exchange)) {
- ServiceEndpointImpl endpoint = (ServiceEndpointImpl) entry.getValue();;
+ ServiceEndpointImpl endpoint = (ServiceEndpointImpl) entry.getValue(); + ;
subscriptionManager.dispatchToSubscriber(exchange, endpoint);
}
}
}
-
- public void registerSubscription(SubscriptionSpec subscription, ServiceEndpointImpl endpoint) {
+
+ public void registerSubscription(SubscriptionSpec subscription, ServiceEndpointImpl endpoint) {
subscriptions.put(subscription, endpoint);
}
-
+
public ServiceEndpointImpl deregisterSubscription(SubscriptionSpec subscription) {
return (ServiceEndpointImpl) subscriptions.remove(subscription);
}
-
+
}
