Class InboundTask
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.InboundTask
-
- All Implemented Interfaces:
org.apache.synapse.ManagedLifecycle
,org.apache.synapse.task.Task
,PinnedPollingTask
- Direct Known Subclasses:
GenericTask
,JMSTask
,KAFKATask
public abstract class InboundTask extends Object implements org.apache.synapse.task.Task, org.apache.synapse.ManagedLifecycle, PinnedPollingTask
This class provides Generic Task implementation for inbound polling
-
-
Field Summary
Fields Modifier and Type Field Description protected long
interval
static int
TASK_THRESHOLD_INTERVAL
-
Constructor Summary
Constructors Constructor Description InboundTask()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
execute()
abstract Properties
getInboundProperties()
protected abstract void
taskExecute()
-
-
-
Field Detail
-
interval
protected long interval
-
TASK_THRESHOLD_INTERVAL
public static final int TASK_THRESHOLD_INTERVAL
- See Also:
- Constant Field Values
-
-
Method Detail
-
execute
public void execute()
- Specified by:
execute
in interfaceorg.apache.synapse.task.Task
-
taskExecute
protected abstract void taskExecute()
-
getInboundProperties
public abstract Properties getInboundProperties()
- Specified by:
getInboundProperties
in interfacePinnedPollingTask
-
-