Package org.wso2.carbon.inbound.endpoint.common

Class InboundOneTimeTriggerRequestProcessor

java.lang.Object
org.wso2.carbon.inbound.endpoint.common.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 Details

    • startUpController

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

    • synapseEnvironment

      protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment

    • name

      protected String name

    • coordination

      protected boolean coordination

    • startInPausedMode

      protected boolean startInPausedMode

    • COMMON_ENDPOINT_POSTFIX

      protected static final String COMMON_ENDPOINT_POSTFIX
      See Also:

    • TASK_THRESHOLD_INTERVAL

      public static final int TASK_THRESHOLD_INTERVAL
      See Also:

  • Constructor Details

    • InboundOneTimeTriggerRequestProcessor

      public InboundOneTimeTriggerRequestProcessor()

  • Method Details

    • 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

    • activate

      public boolean activate()
      Specified by:
      activate in interface org.apache.synapse.inbound.InboundRequestProcessor

    • deactivate

      public boolean deactivate()
      Specified by:
      deactivate in interface org.apache.synapse.inbound.InboundRequestProcessor

    • isDeactivated

      public boolean isDeactivated()
      Specified by:
      isDeactivated in interface org.apache.synapse.inbound.InboundRequestProcessor

    • pause

      public void pause()
      Specified by:
      pause in interface org.apache.synapse.inbound.InboundRequestProcessor