Class InboundOneTimeTriggerRequestProcessor

  • All Implemented Interfaces:
    org.apache.synapse.inbound.InboundRequestProcessor
    Direct Known Subclasses:
    InboundOneTimeTriggerEventBasedProcessor, MqttListener, RabbitMQListener

    public abstract class InboundOneTimeTriggerRequestProcessor
    extends Object
    implements org.apache.synapse.inbound.InboundRequestProcessor
    This class provides the common implementation for one time trigger protocol processors Implemented the support if message injection happens in a separate thread. ( using Callbacks ) One such requirement is loading the tenant when message is injected if at that moment tenant is unloaded.
    • Field Detail

      • startUpController

        protected org.apache.synapse.startup.quartz.StartUpController startUpController
      • synapseEnvironment

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

        protected boolean coordination
      • TASK_THRESHOLD_INTERVAL

        public static final int TASK_THRESHOLD_INTERVAL
        See Also:
        Constant Field Values
    • Constructor Detail

      • InboundOneTimeTriggerRequestProcessor

        public InboundOneTimeTriggerRequestProcessor()
    • Method Detail

      • start

        protected void start​(OneTimeTriggerInboundTask 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