Class JMSTask
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.InboundTask
-
- org.wso2.carbon.inbound.endpoint.protocol.jms.JMSTask
-
- All Implemented Interfaces:
org.apache.synapse.ManagedLifecycle
,org.apache.synapse.task.Task
,PinnedPollingTask
,org.wso2.carbon.ntask.core.impl.LocalTaskActionListener
public class JMSTask extends InboundTask implements org.wso2.carbon.ntask.core.impl.LocalTaskActionListener
JMSTask class is used to schedule the inbound execution when the coordination is required
-
-
Field Summary
-
Fields inherited from class org.wso2.carbon.inbound.endpoint.common.InboundTask
interval, TASK_THRESHOLD_INTERVAL
-
-
Constructor Summary
Constructors Constructor Description JMSTask(JMSPollingConsumer jmsPollingConsumer, long interval)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Properties
getInboundProperties()
void
init(org.apache.synapse.core.SynapseEnvironment synapseEnvironment)
void
notifyLocalTaskDeletion(String taskName)
protected void
taskExecute()
-
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundTask
execute
-
-
-
-
Constructor Detail
-
JMSTask
public JMSTask(JMSPollingConsumer jmsPollingConsumer, long interval)
-
-
Method Detail
-
taskExecute
protected void taskExecute()
- Specified by:
taskExecute
in classInboundTask
-
getInboundProperties
public Properties getInboundProperties()
- Specified by:
getInboundProperties
in interfacePinnedPollingTask
- Specified by:
getInboundProperties
in classInboundTask
-
init
public void init(org.apache.synapse.core.SynapseEnvironment synapseEnvironment)
- Specified by:
init
in interfaceorg.apache.synapse.ManagedLifecycle
-
destroy
public void destroy()
- Specified by:
destroy
in interfaceorg.apache.synapse.ManagedLifecycle
-
notifyLocalTaskDeletion
public void notifyLocalTaskDeletion(String taskName)
Destroys the JMS task upon deletion of the local task.
- Specified by:
notifyLocalTaskDeletion
in interfaceorg.wso2.carbon.ntask.core.impl.LocalTaskActionListener
- Parameters:
taskName
- the name of the task that was deleted
-
-