1 17 package org.apache.servicemix.components.jaxrpc; 18 19 import javax.jbi.messaging.MessageExchange; 20 import javax.jbi.messaging.NormalizedMessage; 21 import javax.xml.rpc.Call ; 22 23 import org.apache.servicemix.components.util.OutBinding; 24 25 28 public class JaxRpcInBinding extends OutBinding { 29 private JaxRpcMarshaler marshaler = new JaxRpcMarshaler(); 30 31 32 protected void process(MessageExchange messageExchange, NormalizedMessage inMessage) throws Exception { 33 Call call = marshaler.createCall(inMessage); 34 Object [] params = marshaler.getCallParams(inMessage); 35 36 call.invokeOneWay(params); 37 done(messageExchange); 38 } 39 } | Popular Tags |