Package org.wso2.carbon.inbound.endpoint.protocol.kafka

Class KAFKATask

java.lang.Object

org.wso2.carbon.inbound.endpoint.common.InboundTask

org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKATask

All Implemented Interfaces:

org.apache.synapse.ManagedLifecycle, org.apache.synapse.task.Task, PinnedPollingTask

public class KAFKATask
extends InboundTask

Field Summary

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

interval, TASK_THRESHOLD_INTERVAL

Constructor Summary

Constructors

Constructor	Description
KAFKATask(KAFKAPollingConsumer kafkaPollingConsumer, long interval)

Method Summary

Modifier and Type	Method	Description
void	destroy()
Properties	getInboundProperties()
void	init(org.apache.synapse.core.SynapseEnvironment se)
void	taskExecute()

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

execute

Methods inherited from class java.lang.Object

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

Constructor Details

KAFKATask

public KAFKATask(KAFKAPollingConsumer kafkaPollingConsumer,
 long interval)

Method Details

init

public void init(org.apache.synapse.core.SynapseEnvironment se)

destroy

public void destroy()

taskExecute

public void taskExecute()

Specified by:

taskExecute in class InboundTask

getInboundProperties

public Properties getInboundProperties()

Specified by:

getInboundProperties in interface PinnedPollingTask

Specified by:

getInboundProperties in class InboundTask