You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ch...@apache.org on 2007/09/21 19:34:18 UTC
svn commit: r578207 - in
/incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src:
main/java/org/apache/servicemix/camel/JbiMessage.java
test/java/org/apache/servicemix/camel/SendFromCamelToJbiAndBackToCamelTest.java
Author: chirino
Date: Fri Sep 21 10:34:18 2007
New Revision: 578207
URL: http://svn.apache.org/viewvc?rev=578207&view=rev
Log:
Update to the latest version of the camel SEDA component
Modified:
incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiMessage.java
incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/test/java/org/apache/servicemix/camel/SendFromCamelToJbiAndBackToCamelTest.java
Modified: incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiMessage.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiMessage.java?rev=578207&r1=578206&r2=578207&view=diff
==============================================================================
--- incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiMessage.java (original)
+++ incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/main/java/org/apache/servicemix/camel/JbiMessage.java Fri Sep 21 10:34:18 2007
@@ -105,7 +105,7 @@
}
}
- @Override
+// @Override
public void setBody(Object body) {
if (normalizedMessage != null) {
if (!(body instanceof Source)) {
Modified: incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/test/java/org/apache/servicemix/camel/SendFromCamelToJbiAndBackToCamelTest.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/test/java/org/apache/servicemix/camel/SendFromCamelToJbiAndBackToCamelTest.java?rev=578207&r1=578206&r2=578207&view=diff
==============================================================================
--- incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/test/java/org/apache/servicemix/camel/SendFromCamelToJbiAndBackToCamelTest.java (original)
+++ incubator/servicemix/trunk/deployables/serviceengines/servicemix-camel/src/test/java/org/apache/servicemix/camel/SendFromCamelToJbiAndBackToCamelTest.java Fri Sep 21 10:34:18 2007
@@ -22,6 +22,7 @@
import javax.xml.namespace.QName;
+import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.seda.SedaEndpoint;
import org.apache.servicemix.jbi.container.ActivationSpec;
@@ -40,15 +41,15 @@
SedaEndpoint receiverEndpoint = (SedaEndpoint) camelContext
.getEndpoint("seda:receiver");
- BlockingQueue<SedaEndpoint.Entry> queue = receiverEndpoint.getQueue();
- SedaEndpoint.Entry entry = queue.poll(5, TimeUnit.SECONDS);
+ BlockingQueue<Exchange> queue = receiverEndpoint.getQueue();
+ Exchange exchange = queue.poll(5, TimeUnit.SECONDS);
assertNotNull(
"Camel Receiver queue should have received an exchange by now",
- entry);
+ exchange);
- log.debug("Receiver got exchange: " + entry.getExchange() + " with body: "
- + entry.getExchange().getIn().getBody());
+ log.debug("Receiver got exchange: " + exchange + " with body: "
+ + exchange.getIn().getBody());
}
@Override