org.openkilda.northbound.messaging.MessageConsumer< T > Interface Template Reference

Inheritance diagram for org.openkilda.northbound.messaging.MessageConsumer< T >:

Public Member Functions
T	poll (final String correlationId)
void	clear ()

Public Attributes
int	POLL_TIMEOUT = 120 * 1000
int	POLL_PAUSE = 100

Detailed Description

Definition at line 18 of file MessageConsumer.java.

Member Function Documentation

clear()

void org.openkilda.northbound.messaging.MessageConsumer< T >.clear

(

)

Clears message queue.

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

poll()

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

(

final String

correlationId

)

Polls Kafka message queue.

Parameters

correlationId

correlation id

Returns

received message

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

Member Data Documentation

POLL_PAUSE

int org.openkilda.northbound.messaging.MessageConsumer< T >.POLL_PAUSE = 100

Kafka message queue poll pause.

Definition at line 27 of file MessageConsumer.java.

POLL_TIMEOUT

int org.openkilda.northbound.messaging.MessageConsumer< T >.POLL_TIMEOUT = 120 * 1000

Kafka message queue poll timeout.

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