Author: ffang
Date: Wed Feb 18 09:50:52 2009
New Revision: 745457
URL: http://svn.apache.org/viewvc?rev=745457&view=rev
Log:
[SMX4NMR-91 SMX4NMR-92]follow the JBI rule for InOut pattern
Modified:
servicemix/smx4/nmr/trunk/examples/nmr/client/src/main/java/org/apache/servicemix/nmr/examples/nmr/client/Client.java
servicemix/smx4/nmr/trunk/examples/nmr/endpoint/src/main/java/org/apache/servicemix/nmr/examples/nmr/endpoint/EchoEndpoint.java
Modified:
servicemix/smx4/nmr/trunk/examples/nmr/client/src/main/java/org/apache/servicemix/nmr/examples/nmr/client/Client.java
URL:
http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/examples/nmr/client/src/main/java/org/apache/servicemix/nmr/examples/nmr/client/Client.java?rev=745457&r1=745456&r2=745457&view=diff
==============================================================================
---
servicemix/smx4/nmr/trunk/examples/nmr/client/src/main/java/org/apache/servicemix/nmr/examples/nmr/client/Client.java
(original)
+++
servicemix/smx4/nmr/trunk/examples/nmr/client/src/main/java/org/apache/servicemix/nmr/examples/nmr/client/Client.java
Wed Feb 18 09:50:52 2009
@@ -23,6 +23,7 @@
import org.apache.servicemix.nmr.api.Exchange;
import org.apache.servicemix.nmr.api.NMR;
import org.apache.servicemix.nmr.api.Pattern;
+import org.apache.servicemix.nmr.api.Status;
import org.apache.servicemix.nmr.api.service.ServiceHelper;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.InitializingBean;
@@ -67,6 +68,8 @@
e.getIn().setBody("Hello");
client.sendSync(e);
LOG.info("Response from Endpoint " +
e.getOut().getBody());
+ e.setStatus(Status.Done);
+ client.send(e);
}
} catch (Exception e) {
e.printStackTrace();
Modified:
servicemix/smx4/nmr/trunk/examples/nmr/endpoint/src/main/java/org/apache/servicemix/nmr/examples/nmr/endpoint/EchoEndpoint.java
URL:
http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/examples/nmr/endpoint/src/main/java/org/apache/servicemix/nmr/examples/nmr/endpoint/EchoEndpoint.java?rev=745457&r1=745456&r2=745457&view=diff
==============================================================================
---
servicemix/smx4/nmr/trunk/examples/nmr/endpoint/src/main/java/org/apache/servicemix/nmr/examples/nmr/endpoint/EchoEndpoint.java
(original)
+++
servicemix/smx4/nmr/trunk/examples/nmr/endpoint/src/main/java/org/apache/servicemix/nmr/examples/nmr/endpoint/EchoEndpoint.java
Wed Feb 18 09:50:52 2009
@@ -27,10 +27,11 @@
private static final transient Log LOG =
LogFactory.getLog(EchoEndpoint.class);
private Channel channel;
public void process(Exchange exchange) {
- LOG.info("Received in EchoEndpoint: " + exchange.getIn().getBody());
- exchange.getOut().setBody("Echo" + exchange.getIn().getBody(),
String.class);
- exchange.setStatus(Status.Done);
- channel.send(exchange);
+ if (exchange.getStatus().equals(Status.Active)) {
+ LOG.info("Received in EchoEndpoint: " + exchange.getIn().getBody());
+ exchange.getOut().setBody("Echo" + exchange.getIn().getBody(),
String.class);
+ channel.send(exchange);
+ }
}
public void setChannel(Channel channel) {
