Class RPCResponse

  • All Implemented Interfaces:
    java.io.Externalizable , java.io.Serializable , java.lang.Comparable , org.apache.avro.generic.GenericContainer , org.apache.avro.generic.GenericRecord , org.apache.avro.generic.IndexedRecord , org.apache.avro.specific.SpecificRecord

    
    public class RPCResponse
    extends SpecificRecordBase implements SpecificRecord
                        

    Response envelope for RPC message pattern

    • Constructor Detail

      • RPCResponse

        RPCResponse()
        Default constructor.
      • RPCResponse

        RPCResponse(String sender, String correlationKey, Instant sendTime, ResponseStatus responseStatus, ByteBuffer payload)
        All-args constructor.
        Parameters:
        sender - The sender identifier
        correlationKey - Unique identifier
        sendTime - Time ([Instant]) in milliseconds of the response
        responseStatus - Status enum on the response to help with response handling
        payload - The new value for payload