svn commit: r662237 - in /activemq/camel/trunk/components/camel-cxf/src: main/java/org/apache/camel/component/cxf/CamelInvoker.java test/java/org/apache/camel/wsdl_first/PersonImpl.java

[ningjiang]

Author: ningjiang
Date: Sun Jun  1 08:35:54 2008
New Revision: 662237

URL: http://svn.apache.org/viewvc?rev=662237&view=rev
Log:
CAMEL-568 patch applied with thanks to Freeman

Modified:
    
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CamelInvoker.java
    
activemq/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/wsdl_first/PersonImpl.java

Modified: 
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CamelInvoker.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CamelInvoker.java?rev=662237&r1=662236&r2=662237&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CamelInvoker.java
 (original)
+++ 
activemq/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CamelInvoker.java
 Sun Jun  1 08:35:54 2008
@@ -55,6 +55,14 @@
         //TODO set the request context here
         CxfEndpoint endpoint = cxfConsumer.getEndpoint();
         CxfExchange cxfExchange = endpoint.createExchange(inMessage);
+        
+        BindingOperationInfo bop = exchange.get(BindingOperationInfo.class);
+        
+        if (bop != null && bop.getOperationInfo().isOneWay()) {
+            cxfExchange.setPattern(ExchangePattern.InOnly);
+        } else {
+            cxfExchange.setPattern(ExchangePattern.InOut);
+        }
         try {
             cxfConsumer.getProcessor().process(cxfExchange);
         } catch (Exception ex) {

Modified: 
activemq/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/wsdl_first/PersonImpl.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/wsdl_first/PersonImpl.java?rev=662237&r1=662236&r2=662237&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/wsdl_first/PersonImpl.java
 (original)
+++ 
activemq/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/wsdl_first/PersonImpl.java
 Sun Jun  1 08:35:54 2008
@@ -26,7 +26,7 @@
 
     public void getPerson(Holder<String> personId, Holder<String> ssn,
             Holder<String> name) throws UnknownPersonFault {
-        System.out.println("the server is invoked ");
+        //System.out.println("the server is invoked ");
         if (personId.value == null || personId.value.length() == 0) {
             org.apache.camel.wsdl_first.types.UnknownPersonFault
                 fault = new 
org.apache.camel.wsdl_first.types.UnknownPersonFault();