org.openkilda.floodlight.kafka.TestAwareConsumer Class Reference

Inheritance diagram for org.openkilda.floodlight.kafka.TestAwareConsumer:

Public Member Functions
	TestAwareConsumer (ConsumerContext context, KafkaConsumerConfig kafkaConfig, ExecutorService handlersPool, Factory handlerFactory, ISwitchManager switchManager, String topic, String... moreTopics)
Public Member Functions inherited from org.openkilda.floodlight.kafka.Consumer
	Consumer (KafkaConsumerConfig kafkaConfig, ExecutorService handlersPool, RecordHandler.Factory handlerFactory, ISwitchManager switchManager, String topic, String... moreTopics)
void	run ()

Protected Member Functions
void	handle (ConsumerRecord< String, String > record)
Protected Member Functions inherited from org.openkilda.floodlight.kafka.Consumer
void	handle (ConsumerRecord< String, String > record)

Detailed Description

Definition at line 32 of file TestAwareConsumer.java.

Constructor & Destructor Documentation

TestAwareConsumer()

org.openkilda.floodlight.kafka.TestAwareConsumer.TestAwareConsumer	(	ConsumerContext	context,
		KafkaConsumerConfig	kafkaConfig,
		ExecutorService	handlersPool,
		Factory	handlerFactory,
		ISwitchManager	switchManager,
		String	topic,
		String...	moreTopics
	)

Definition at line 38 of file TestAwareConsumer.java.

Member Function Documentation

handle()

void org.openkilda.floodlight.kafka.TestAwareConsumer.handle ( ConsumerRecord< String, String >  record )

protected

Definition at line 54 of file TestAwareConsumer.java.

---

The documentation for this class was generated from the following file:

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/src/floodlight-modules/src/main/java/org/openkilda/floodlight/kafka/TestAwareConsumer.java