Class InboundRMHttpInvoker
- java.lang.Object
-
- org.apache.cxf.service.invoker.AbstractInvoker
-
- org.wso2.carbon.inbound.endpoint.ext.wsrm.invoker.InboundRMHttpInvoker
-
- All Implemented Interfaces:
org.apache.cxf.service.invoker.Invoker
public class InboundRMHttpInvoker extends org.apache.cxf.service.invoker.AbstractInvoker
After the RM protocol messages are processed, the request is processed here
-
-
Constructor Summary
Constructors Constructor Description InboundRMHttpInvoker(Object bean, String injectingSequence, String onErrorSequence)
Constructor for the invoker
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ExecutorService
getExecutorService()
Object
getServiceObject(org.apache.cxf.message.Exchange exchange)
Object
invoke(org.apache.cxf.message.Exchange exchange, Object o)
This is where the the incoming request from the CXF Bus is paused and handed to Synapsevoid
setExecutorService(ExecutorService executorService)
-
-
-
Constructor Detail
-
InboundRMHttpInvoker
public InboundRMHttpInvoker(Object bean, String injectingSequence, String onErrorSequence)
Constructor for the invoker- Parameters:
bean
- An instance of the backend business logic implementing classinjectingSequence
- The injecting sequence nameonErrorSequence
- The fault sequence name
-
-
Method Detail
-
getServiceObject
public Object getServiceObject(org.apache.cxf.message.Exchange exchange)
- Specified by:
getServiceObject
in classorg.apache.cxf.service.invoker.AbstractInvoker
-
invoke
public Object invoke(org.apache.cxf.message.Exchange exchange, Object o)
This is where the the incoming request from the CXF Bus is paused and handed to Synapse- Specified by:
invoke
in interfaceorg.apache.cxf.service.invoker.Invoker
- Overrides:
invoke
in classorg.apache.cxf.service.invoker.AbstractInvoker
- Parameters:
exchange
- exchange that contains the messageso
- the dummy back end object- Returns:
- null
-
getExecutorService
public ExecutorService getExecutorService()
-
setExecutorService
public final void setExecutorService(ExecutorService executorService)
-
-