public class KAFKAPollingConsumer extends Object
Modifier and Type | Field and Description |
---|---|
protected AbstractKafkaMessageListener |
messageListener |
Constructor and Description |
---|
KAFKAPollingConsumer(Properties kafkaProperties,
long interval,
String name)
Initialize the kafka properties and the polling interval
|
Modifier and Type | Method and Description |
---|---|
void |
execute() |
Properties |
getInboundProperties() |
Object |
poll()
Create the connection with the zookeeper and inject the messages to the sequence
|
void |
registerHandler(InjectHandler processingHandler)
Register a handler to implement injection of the retrieved message
|
void |
startsMessageListener()
Start the listener to listen when new messages come to the esb,the listener can be high level or low level.
|
protected AbstractKafkaMessageListener messageListener
public KAFKAPollingConsumer(Properties kafkaProperties, long interval, String name) throws Exception
Exception
public void startsMessageListener() throws Exception
Exception
public void execute()
public void registerHandler(InjectHandler processingHandler)
processingHandler
- public Object poll()
public Properties getInboundProperties()
Copyright © 2019 WSO2. All rights reserved.