org.openkilda.northbound.messaging.MessageProducer Interface Reference

Inheritance diagram for org.openkilda.northbound.messaging.MessageProducer:

Public Member Functions
void	send (final String topic, final Message message)

Public Attributes
int	TIMEOUT = 1000

Detailed Description

Definition at line 20 of file MessageProducer.java.

Member Function Documentation

send()

void org.openkilda.northbound.messaging.MessageProducer.send	(	final String	topic,
		final Message	message
	)

Sends messages to WorkFlowManager.

Parameters

topic	kafka topic
message	message to serialize and send

Implemented in org.openkilda.northbound.controller.TestMessageMock, org.openkilda.northbound.messaging.kafka.KafkaMessageProducer, and org.openkilda.northbound.MessageExchanger.

Member Data Documentation

TIMEOUT

int org.openkilda.northbound.messaging.MessageProducer.TIMEOUT = 1000

Kafka message send timeout.

Definition at line 24 of file MessageProducer.java.

---

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

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/src/northbound/src/main/java/org/openkilda/northbound/messaging/MessageProducer.java