org.openkilda.floodlight.kafka.TestAwareProducer Class Reference

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

Public Member Functions
	TestAwareProducer (KafkaProducerConfig kafkaConfig)
void	sendMessageAndTrack (String topic, Message message)
SendStatus	sendMessage (String topic, Message message)
KafkaBreakTrigger	getBreakTrigger ()
Public Member Functions inherited from org.openkilda.floodlight.kafka.producer.Producer
	Producer (KafkaProducerConfig kafkaConfig)
synchronized void	enableGuaranteedOrder (String topic)
synchronized void	disableGuaranteedOrder (String topic)
synchronized void	disableGuaranteedOrder (String topic, long transitionPeriod)
void	sendMessageAndTrack (String topic, Message message)
SendStatus	sendMessage (String topic, Message message)

Detailed Description

Definition at line 28 of file TestAwareProducer.java.

Constructor & Destructor Documentation

TestAwareProducer()

org.openkilda.floodlight.kafka.TestAwareProducer.TestAwareProducer

(

KafkaProducerConfig

kafkaConfig

)

Definition at line 33 of file TestAwareProducer.java.

Member Function Documentation

getBreakTrigger()

KafkaBreakTrigger org.openkilda.floodlight.kafka.TestAwareProducer.getBreakTrigger

(

)

Definition at line 58 of file TestAwareProducer.java.

sendMessage()

SendStatus org.openkilda.floodlight.kafka.TestAwareProducer.sendMessage	(	String	topic,
		Message	message
	)

Definition at line 49 of file TestAwareProducer.java.

sendMessageAndTrack()

void org.openkilda.floodlight.kafka.TestAwareProducer.sendMessageAndTrack	(	String	topic,
		Message	message
	)

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