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

Class InboundOneTimeTriggerEventBasedProcessor

java.lang.Object

org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor

org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerEventBasedProcessor

All Implemented Interfaces:

org.apache.synapse.inbound.InboundRequestProcessor

Direct Known Subclasses:

GenericEventBasedListener

public abstract class InboundOneTimeTriggerEventBasedProcessor
extends InboundOneTimeTriggerRequestProcessor

Field Summary

Fields inherited from class org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor

COMMON_ENDPOINT_POSTFIX, coordination, name, startInPausedMode, startUpController, synapseEnvironment, TASK_THRESHOLD_INTERVAL

Constructor Summary

Constructors

Constructor	Description
InboundOneTimeTriggerEventBasedProcessor()

Method Summary

Modifier and Type	Method	Description
void	destroy()	Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop
protected void	start(GenericOneTimeTask task, String endpointPostfix)	Based on the coordination option schedule the task with NTASK or run as a background thread

Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor

activate, deactivate, isDeactivated, pause, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.synapse.inbound.InboundRequestProcessor

init

Constructor Details

InboundOneTimeTriggerEventBasedProcessor

public InboundOneTimeTriggerEventBasedProcessor()

Method Details

start

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

Overrides:

destroy in class InboundOneTimeTriggerRequestProcessor