Class InboundRequestProcessorImpl

  • All Implemented Interfaces:
    org.apache.synapse.inbound.InboundRequestProcessor
    Direct Known Subclasses:
    GenericProcessor, JMSProcessor, KAFKAProcessor

    public abstract class InboundRequestProcessorImpl
    extends Object
    implements org.apache.synapse.inbound.InboundRequestProcessor
    This class provides the common implementation for polling protocol processors
    • Field Detail

      • synapseEnvironment

        protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
      • interval

        protected long interval
      • coordination

        protected boolean coordination
    • Constructor Detail

      • InboundRequestProcessorImpl

        public InboundRequestProcessorImpl()
    • Method Detail

      • start

        protected void start​(InboundTask task,
                             String endpointPostfix)
        Based on the coordination option schedule the task with NTASK or run as a background thread
        Parameters:
        task -
        endpointPostfix -
      • destroy

        public void destroy()
        Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop
        Specified by:
        destroy in interface org.apache.synapse.inbound.InboundRequestProcessor
      • isPinnedServerEnabled

        protected static boolean isPinnedServerEnabled​(Properties inboundProperties)
      • isPinnedServer

        protected boolean isPinnedServer​(Properties inboundProperties)