Class 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 Detail

      • 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 Detail

      • 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
      • setExecutorService

        public final void setExecutorService​(ExecutorService executorService)