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

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 final int	TASK_THRESHOLD_INTERVAL

Constructor Summary

Constructors

Constructor	Description
InboundTask()

Method Summary

Modifier and Type	Method	Description
void	execute()
abstract Properties	getInboundProperties()
protected abstract void	taskExecute()

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.ManagedLifecycle

destroy, init

Field Details

interval

protected long interval

TASK_THRESHOLD_INTERVAL

public static final int TASK_THRESHOLD_INTERVAL

See Also:

• Constant Field Values

Constructor Details

InboundTask

public InboundTask()

Method Details

execute

public void execute()

Specified by:

execute in interface org.apache.synapse.task.Task

taskExecute

protected abstract void taskExecute()

getInboundProperties

public abstract Properties getInboundProperties()

Specified by:

getInboundProperties in interface PinnedPollingTask