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 Summary
Fields Modifier and Type Field Description protected static String
COMMON_ENDPOINT_POSTFIX
protected boolean
coordination
protected String
name
protected org.apache.synapse.startup.quartz.StartUpController
startUpController
protected org.apache.synapse.core.SynapseEnvironment
synapseEnvironment
static int
TASK_THRESHOLD_INTERVAL
-
Constructor Summary
Constructors Constructor Description InboundOneTimeTriggerRequestProcessor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stopprotected void
start(OneTimeTriggerInboundTask task, String endpointPostfix)
Based on the coordination option schedule the task with NTASK or run as a background thread
-
-
-
Field Detail
-
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
-
COMMON_ENDPOINT_POSTFIX
protected static final String COMMON_ENDPOINT_POSTFIX
- See Also:
- Constant Field Values
-
TASK_THRESHOLD_INTERVAL
public static final int TASK_THRESHOLD_INTERVAL
- See Also:
- Constant Field Values
-
-
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 interfaceorg.apache.synapse.inbound.InboundRequestProcessor
-
-