camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bvah...@apache.org
Subject svn commit: r1350778 - /camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
Date Fri, 15 Jun 2012 20:18:37 GMT
Author: bvahdat
Date: Fri Jun 15 20:18:37 2012
New Revision: 1350778

URL: http://svn.apache.org/viewvc?rev=1350778&view=rev
Log:
Removed the obsolete put call to CONSUMERS map of DirectVmComponent.

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java?rev=1350778&r1=1350777&r2=1350778&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
Fri Jun 15 20:18:37 2012
@@ -56,7 +56,6 @@ public class DirectVmComponent extends D
             String contextId = existing.getEndpoint().getCamelContext().getName();
             throw new IllegalStateException("A consumer " + existing + " already exists from
CamelContext: " + contextId + ". Multiple consumers not supported");
         }
-        CONSUMERS.put(key, consumer);
     }
 
     public void removeConsumer(DirectVmEndpoint endpoint, DirectVmConsumer consumer) {
@@ -84,6 +83,7 @@ public class DirectVmComponent extends D
             // clear queues when no more direct-vm components in use
             CONSUMERS.clear();
         }
+        super.doStop();
     }
 
 }



Mime
View raw message