public abstract class InboundOneTimeTriggerRequestProcessor extends Object implements org.apache.synapse.inbound.InboundRequestProcessor
Modifier and Type | Field and 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 and Description |
---|
InboundOneTimeTriggerRequestProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Stop the inbound polling processor This will be called when inbound is
undeployed/redeployed or when server stop
|
protected void |
start(OneTimeTriggerInboundTask task,
String endpointPostfix)
Based on the coordination option schedule the task with NTASK or run as a
background thread
|
protected org.apache.synapse.startup.quartz.StartUpController startUpController
protected org.apache.synapse.core.SynapseEnvironment synapseEnvironment
protected String name
protected boolean coordination
protected static final String COMMON_ENDPOINT_POSTFIX
public static final int TASK_THRESHOLD_INTERVAL
public InboundOneTimeTriggerRequestProcessor()
protected void start(OneTimeTriggerInboundTask task, String endpointPostfix)
task
- endpointPostfix
- public void destroy()
destroy
in interface org.apache.synapse.inbound.InboundRequestProcessor
Copyright © 2019 WSO2. All rights reserved.