org.openkilda.floodlight.kafka.KafkaMessageProducer Class Reference

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

Public Member Functions
Collection< Class<? extends IFloodlightService > >	getModuleServices ()
Map< Class<? extends IFloodlightService >, IFloodlightService >	getServiceImpls ()
Collection< Class<? extends IFloodlightService > >	getModuleDependencies ()
void	init (FloodlightModuleContext moduleContext) throws FloodlightModuleException
void	startUp (FloodlightModuleContext floodlightModuleContext) throws FloodlightModuleException
void	postMessage (final String topic, final Message message)
Producer	getProducer ()

Detailed Description

Created by jonv on 6/3/17.

Definition at line 36 of file KafkaMessageProducer.java.

Member Function Documentation

getModuleDependencies()

Collection<Class<? extends IFloodlightService> > org.openkilda.floodlight.kafka.KafkaMessageProducer.getModuleDependencies

(

)

Definition at line 60 of file KafkaMessageProducer.java.

getModuleServices()

Collection<Class<? extends IFloodlightService> > org.openkilda.floodlight.kafka.KafkaMessageProducer.getModuleServices

(

)

Definition at line 44 of file KafkaMessageProducer.java.

getProducer()

Producer org.openkilda.floodlight.kafka.KafkaMessageProducer.getProducer

(

)

Definition at line 107 of file KafkaMessageProducer.java.

getServiceImpls()

Map<Class<? extends IFloodlightService>, IFloodlightService> org.openkilda.floodlight.kafka.KafkaMessageProducer.getServiceImpls

(

)

Definition at line 52 of file KafkaMessageProducer.java.

init()

void org.openkilda.floodlight.kafka.KafkaMessageProducer.init

(

FloodlightModuleContext

moduleContext

)

throws FloodlightModuleException

Definition at line 68 of file KafkaMessageProducer.java.

postMessage()

void org.openkilda.floodlight.kafka.KafkaMessageProducer.postMessage	(	final String	topic,
		final Message	message
	)

Send the message to Kafka.

Parameters

topic	topic to post the message to
message	message to pose

Definition at line 90 of file KafkaMessageProducer.java.

startUp()

void org.openkilda.floodlight.kafka.KafkaMessageProducer.startUp

(

FloodlightModuleContext

floodlightModuleContext

)

throws FloodlightModuleException

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