Package org.wso2.carbon.inbound.endpoint.ext.wsrm.invoker

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

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 Synapse
final void	setExecutorService(ExecutorService executorService)

Methods inherited from class org.apache.cxf.service.invoker.AbstractInvoker

adjustMethodAndParams, checkSuspendedInvocation, createFault, getMostSpecificMethod, insertExchange, invoke, isJdkDynamicProxy, performInvocation, releaseServiceObject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InboundRMHttpInvoker

public InboundRMHttpInvoker(Object bean,
 String injectingSequence,
 String onErrorSequence)

Constructor for the invoker

Parameters:

bean - An instance of the backend business logic implementing class

injectingSequence - The injecting sequence name

onErrorSequence - The fault sequence name

Method Details

getServiceObject

public Object getServiceObject(org.apache.cxf.message.Exchange exchange)

Specified by:

getServiceObject in class org.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 interface org.apache.cxf.service.invoker.Invoker

Overrides:

invoke in class org.apache.cxf.service.invoker.AbstractInvoker

Parameters:

exchange - exchange that contains the messages

o - the dummy back end object

Returns:

null

getExecutorService

public ExecutorService getExecutorService()

setExecutorService

public final void setExecutorService(ExecutorService executorService)