svn commit: r663826 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel: component/dataset/DataSetEndpoint.java impl/DefaultProducerTemplate.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r663826 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel: component/dataset/DataSetEndpoint.java impl/DefaultProducerTemplate.java

davsclaus-2
Author: davsclaus
Date: Thu Jun  5 22:13:57 2008
New Revision: 663826

URL: http://svn.apache.org/viewvc?rev=663826&view=rev
Log:
CAMEL-581: Clearing endpoing chache when stopping. And fixed a typo in DataSetEndpoint

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java?rev=663826&r1=663825&r2=663826&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/dataset/DataSetEndpoint.java Thu Jun  5 22:13:57 2008
@@ -58,7 +58,7 @@
 
     public static void assertEquals(String description, Object expected, Object actual, Exchange exchange) {
         if (!ObjectHelper.equal(expected, actual)) {
-            throw new AssertionError(description + " does not match. Expected: " + expected + " but was: " + actual + " on  " + exchange + " with headers: " + exchange.getIn().getHeaders());
+            throw new AssertionError(description + " does not match. Expected: " + expected + " but was: " + actual + " on " + exchange + " with headers: " + exchange.getIn().getHeaders());
         }
     }
 

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java?rev=663826&r1=663825&r2=663826&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java Thu Jun  5 22:13:57 2008
@@ -302,6 +302,7 @@
 
     protected void doStop() throws Exception {
         producerCache.stop();
+        endpointCache.clear();
     }
 
     protected Object extractResultBody(E result) {