svn commit: r426547 - /incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/Jsr181ExchangeProcessor.java

[gn...@apache.org]

Author: gnodet
Date: Fri Jul 28 08:00:39 2006
New Revision: 426547

URL: http://svn.apache.org/viewvc?rev=426547&view=rev
Log:
Use the operation name provided on the JBI exchange if set

Modified:
    incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/Jsr181ExchangeProcessor.java

Modified: incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/Jsr181ExchangeProcessor.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/Jsr181ExchangeProcessor.java?rev=426547&r1=426546&r2=426547&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/Jsr181ExchangeProcessor.java (original)
+++ incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/Jsr181ExchangeProcessor.java Fri Jul 28 08:00:39 2006
@@ -40,6 +40,7 @@
 import org.codehaus.xfire.MessageContext;
 import org.codehaus.xfire.XFire;
 import org.codehaus.xfire.exchange.InMessage;
+import org.codehaus.xfire.service.OperationInfo;
 import org.codehaus.xfire.service.Service;
 import org.codehaus.xfire.transport.Channel;
 import org.codehaus.xfire.transport.Transport;
@@ -74,6 +75,12 @@
         ctx.setExchange(new org.codehaus.xfire.exchange.MessageExchange(ctx));
         InMessage msg = new InMessage();
         ctx.getExchange().setInMessage(msg);
+        if (exchange.getOperation() != null) {
+            OperationInfo op = service.getServiceInfo().getOperation(exchange.getOperation().getLocalPart());
+            if (op != null) {
+                ctx.getExchange().setOperation(op);
+            }
+        }
         ctx.setCurrentMessage(msg);
         NormalizedMessage in = exchange.getMessage("in");
         msg.setXMLStreamReader(getXMLStreamReader(in.getContent()));
@@ -86,7 +93,6 @@
                 Fault fault = exchange.createFault();
                 fault.setContent(new StringSource(out.toString()));
                 exchange.setFault(fault);
-                exchange.setStatus(ExchangeStatus.ERROR);
             } else {
                 NormalizedMessage outMsg = exchange.createMessage();
                 outMsg.setContent(new StringSource(out.toString()));