Open Kilda Java Documentation
org.openkilda.wfm.protocol.KafkaMessage Class Reference
Inheritance diagram for org.openkilda.wfm.protocol.KafkaMessage:
org.openkilda.wfm.protocol.JsonMessage< Message >

Public Member Functions

 KafkaMessage (Tuple raw) throws MessageFormatException
 
 KafkaMessage (Message payload)
 
- Public Member Functions inherited from org.openkilda.wfm.protocol.JsonMessage< Message >
 JsonMessage (Tuple raw) throws MessageFormatException
 
 JsonMessage (T payload)
 
getPayload ()
 

Protected Member Functions

Message unpackJson (String json) throws IOException
 
- Protected Member Functions inherited from org.openkilda.wfm.protocol.JsonMessage< Message >
abstract T unpackJson (String json) throws IOException
 
Object packField (String fieldId) throws JsonProcessingException
 
Fields getFormat ()
 

Additional Inherited Members

- Static Public Attributes inherited from org.openkilda.wfm.protocol.JsonMessage< Message >
static final String FIELD_ID_JSON
 
static final Fields FORMAT
 

Detailed Description

Definition at line 10 of file KafkaMessage.java.

Constructor & Destructor Documentation

◆ KafkaMessage() [1/2]

org.openkilda.wfm.protocol.KafkaMessage.KafkaMessage ( Tuple  raw) throws MessageFormatException

Definition at line 11 of file KafkaMessage.java.

◆ KafkaMessage() [2/2]

org.openkilda.wfm.protocol.KafkaMessage.KafkaMessage ( Message  payload)

Definition at line 15 of file KafkaMessage.java.

Member Function Documentation

◆ unpackJson()

Message org.openkilda.wfm.protocol.KafkaMessage.unpackJson ( String  json) throws IOException
protected

Definition at line 20 of file KafkaMessage.java.


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