org.openkilda.wfm.topology.TestKafkaConsumer Class Reference

Inheritance diagram for org.openkilda.wfm.topology.TestKafkaConsumer:

Public Member Functions
	TestKafkaConsumer (final String topic, final Destination destination, final Properties properties)
	TestKafkaConsumer (final String topic, final Properties properties)
void	run ()
ConsumerRecord< String, String >	pollMessage () throws InterruptedException
ConsumerRecord< String, String >	pollMessage (final long timeout) throws InterruptedException
String	pollMessageValue () throws InterruptedException
void	clear ()
void	wakeup ()

Detailed Description

Definition at line 36 of file TestKafkaConsumer.java.

Constructor & Destructor Documentation

TestKafkaConsumer() [1/2]

org.openkilda.wfm.topology.TestKafkaConsumer.TestKafkaConsumer	(	final String	topic,
		final Destination	destination,
		final Properties	properties
	)

Definition at line 47 of file TestKafkaConsumer.java.

TestKafkaConsumer() [2/2]

org.openkilda.wfm.topology.TestKafkaConsumer.TestKafkaConsumer	(	final String	topic,
		final Properties	properties
	)

Definition at line 53 of file TestKafkaConsumer.java.

Member Function Documentation

clear()

void org.openkilda.wfm.topology.TestKafkaConsumer.clear

(

)

Definition at line 95 of file TestKafkaConsumer.java.

pollMessage() [1/2]

ConsumerRecord<String, String> org.openkilda.wfm.topology.TestKafkaConsumer.pollMessage

(

)

throws InterruptedException

Definition at line 83 of file TestKafkaConsumer.java.

pollMessage() [2/2]

ConsumerRecord<String, String> org.openkilda.wfm.topology.TestKafkaConsumer.pollMessage

(

final long

timeout

)

throws InterruptedException

Definition at line 87 of file TestKafkaConsumer.java.

pollMessageValue()

String org.openkilda.wfm.topology.TestKafkaConsumer.pollMessageValue

(

)

throws InterruptedException

Definition at line 91 of file TestKafkaConsumer.java.

run()

void org.openkilda.wfm.topology.TestKafkaConsumer.run

(

)

Definition at line 58 of file TestKafkaConsumer.java.

wakeup()

void org.openkilda.wfm.topology.TestKafkaConsumer.wakeup

(

)

Definition at line 99 of file TestKafkaConsumer.java.

---

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

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/wfm/src/test/java/org/openkilda/wfm/topology/TestKafkaConsumer.java