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) {
