org.openkilda.northbound.controller.TestMessageMock Class Reference

Inheritance diagram for org.openkilda.northbound.controller.TestMessageMock:

Public Member Functions
Object	poll (String correlationId)
void	clear ()
void	send (String topic, Message message)

Additional Inherited Members
Public Attributes inherited from org.openkilda.northbound.messaging.MessageProducer
int	TIMEOUT = 1000
Public Attributes inherited from org.openkilda.northbound.messaging.MessageConsumer< T >
int	POLL_TIMEOUT = 120 * 1000
int	POLL_PAUSE = 100

Detailed Description

Spring component which mocks WorkFlow Manager. This instance listens kafka ingoing requests and sends back appropriate kafka responses. Response type choice is based on request type.

Definition at line 67 of file TestMessageMock.java.

Member Function Documentation

clear()

void org.openkilda.northbound.controller.TestMessageMock.clear

(

)

Clears message queue.

Implements org.openkilda.northbound.messaging.MessageConsumer< T >.

Definition at line 132 of file TestMessageMock.java.

poll()

Object org.openkilda.northbound.controller.TestMessageMock.poll

(

String

correlationId

)

Polls Kafka message queue.

Parameters

correlationId

correlation id

Returns

received message

Implements org.openkilda.northbound.messaging.MessageConsumer< T >.

Definition at line 117 of file TestMessageMock.java.

send()

void org.openkilda.northbound.controller.TestMessageMock.send	(	String	topic,
		Message	message
	)

Sends messages to WorkFlowManager.

Parameters

topic	kafka topic
message	message to serialize and send

Implements org.openkilda.northbound.messaging.MessageProducer.

Definition at line 137 of file TestMessageMock.java.

---

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

• /Users/kevin/Desktop/Kilda/open-kilda-develop/services/src/northbound/src/test/java/org/openkilda/northbound/controller/TestMessageMock.java