Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr on MAIN
SubscriptionRegistry.java+10-81.1 -> 1.2
tidied up the code

servicemix/base/src/main/java/org/servicemix/jbi/nmr
SubscriptionRegistry.java 1.1 -> 1.2
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);
     }
-    
+
 }
CVSspam 0.2.8



Reply via email to