org.openkilda.wfm.topology.TestKafkaProducer Class Reference

Public Member Functions
	TestKafkaProducer (final Properties properties)
void	pushMessage (final String topic, final String data)
void	pushMessageAsync (final String topic, final String data)
void	flush ()
void	close ()

Detailed Description

Definition at line 29 of file TestKafkaProducer.java.

Constructor & Destructor Documentation

TestKafkaProducer()

org.openkilda.wfm.topology.TestKafkaProducer.TestKafkaProducer

(

final Properties

properties

)

Definition at line 33 of file TestKafkaProducer.java.

Member Function Documentation

close()

void org.openkilda.wfm.topology.TestKafkaProducer.close

(

)

Definition at line 59 of file TestKafkaProducer.java.

flush()

void org.openkilda.wfm.topology.TestKafkaProducer.flush

(

)

Definition at line 54 of file TestKafkaProducer.java.

pushMessage()

void org.openkilda.wfm.topology.TestKafkaProducer.pushMessage	(	final String	topic,
		final String	data
	)

Definition at line 37 of file TestKafkaProducer.java.

pushMessageAsync()

void org.openkilda.wfm.topology.TestKafkaProducer.pushMessageAsync	(	final String	topic,
		final String	data
	)

Definition at line 49 of file TestKafkaProducer.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/TestKafkaProducer.java