public class KAFKATask extends InboundTask
interval, TASK_THRESHOLD_INTERVAL
Constructor and Description |
---|
KAFKATask(KAFKAPollingConsumer kafkaPollingConsumer,
long interval) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
Properties |
getInboundProperties() |
void |
init(org.apache.synapse.core.SynapseEnvironment se) |
void |
taskExecute() |
execute
public KAFKATask(KAFKAPollingConsumer kafkaPollingConsumer, long interval)
public void init(org.apache.synapse.core.SynapseEnvironment se)
public void destroy()
public void taskExecute()
taskExecute
in class InboundTask
public Properties getInboundProperties()
getInboundProperties
in interface PinnedPollingTask
getInboundProperties
in class InboundTask
Copyright © 2021 WSO2. All rights reserved.