Class RPCRequest.Builder
-
- All Implemented Interfaces:
-
org.apache.avro.data.RecordBuilder
public class RPCRequest.Builder extends SpecificRecordBuilderBase<T> implements RecordBuilder<T>
RecordBuilder for RPCRequest instances.
-
-
Field Summary
Fields Modifier and Type Field Description public String
sender
public String
correlationKey
public Instant
sendTime
public String
replyTopic
public int
replyPartition
public ByteBuffer
payload
-
Method Summary
Modifier and Type Method Description String
getSender()
Gets the value of the 'sender' field. RPCRequest.Builder
setSender(String value)
Sets the value of the 'sender' field. String
getCorrelationKey()
Gets the value of the 'correlationKey' field. RPCRequest.Builder
setCorrelationKey(String value)
Sets the value of the 'correlationKey' field. Instant
getSendTime()
Gets the value of the 'sendTime' field. RPCRequest.Builder
setSendTime(Instant value)
Sets the value of the 'sendTime' field. String
getReplyTopic()
Gets the value of the 'replyTopic' field. RPCRequest.Builder
setReplyTopic(String value)
Sets the value of the 'replyTopic' field. int
getReplyPartition()
Gets the value of the 'replyPartition' field. RPCRequest.Builder
setReplyPartition(int value)
Sets the value of the 'replyPartition' field. ByteBuffer
getPayload()
Gets the value of the 'payload' field. RPCRequest.Builder
setPayload(ByteBuffer value)
Sets the value of the 'payload' field. boolean
hasSender()
Checks whether the 'sender' field has been set. RPCRequest.Builder
clearSender()
Clears the value of the 'sender' field. boolean
hasCorrelationKey()
Checks whether the 'correlationKey' field has been set. RPCRequest.Builder
clearCorrelationKey()
Clears the value of the 'correlationKey' field. boolean
hasSendTime()
Checks whether the 'sendTime' field has been set. RPCRequest.Builder
clearSendTime()
Clears the value of the 'sendTime' field. boolean
hasReplyTopic()
Checks whether the 'replyTopic' field has been set. RPCRequest.Builder
clearReplyTopic()
Clears the value of the 'replyTopic' field. boolean
hasReplyPartition()
Checks whether the 'replyPartition' field has been set. RPCRequest.Builder
clearReplyPartition()
Clears the value of the 'replyPartition' field. boolean
hasPayload()
Checks whether the 'payload' field has been set. RPCRequest.Builder
clearPayload()
Clears the value of the 'payload' field. RPCRequest
build()
-
-
Method Detail
-
setSender
RPCRequest.Builder setSender(String value)
Sets the value of the 'sender' field. The sender identifier
- Parameters:
value
- The value of 'sender'.
-
getCorrelationKey
String getCorrelationKey()
Gets the value of the 'correlationKey' field. Unique identifier
-
setCorrelationKey
RPCRequest.Builder setCorrelationKey(String value)
Sets the value of the 'correlationKey' field. Unique identifier
- Parameters:
value
- The value of 'correlationKey'.
-
getSendTime
Instant getSendTime()
Gets the value of the 'sendTime' field. Time ([Instant]) in milliseconds of the request
-
setSendTime
RPCRequest.Builder setSendTime(Instant value)
Sets the value of the 'sendTime' field. Time ([Instant]) in milliseconds of the request
- Parameters:
value
- The value of 'sendTime'.
-
getReplyTopic
String getReplyTopic()
Gets the value of the 'replyTopic' field. The topic the response needs to be posted on
-
setReplyTopic
RPCRequest.Builder setReplyTopic(String value)
Sets the value of the 'replyTopic' field. The topic the response needs to be posted on
- Parameters:
value
- The value of 'replyTopic'.
-
getReplyPartition
int getReplyPartition()
Gets the value of the 'replyPartition' field. The partition we expect the response to be on
-
setReplyPartition
RPCRequest.Builder setReplyPartition(int value)
Sets the value of the 'replyPartition' field. The partition we expect the response to be on
- Parameters:
value
- The value of 'replyPartition'.
-
getPayload
ByteBuffer getPayload()
Gets the value of the 'payload' field.
-
setPayload
RPCRequest.Builder setPayload(ByteBuffer value)
Sets the value of the 'payload' field.
- Parameters:
value
- The value of 'payload'.
-
hasSender
boolean hasSender()
Checks whether the 'sender' field has been set. The sender identifier
-
clearSender
RPCRequest.Builder clearSender()
Clears the value of the 'sender' field. The sender identifier
-
hasCorrelationKey
boolean hasCorrelationKey()
Checks whether the 'correlationKey' field has been set. Unique identifier
-
clearCorrelationKey
RPCRequest.Builder clearCorrelationKey()
Clears the value of the 'correlationKey' field. Unique identifier
-
hasSendTime
boolean hasSendTime()
Checks whether the 'sendTime' field has been set. Time ([Instant]) in milliseconds of the request
-
clearSendTime
RPCRequest.Builder clearSendTime()
Clears the value of the 'sendTime' field. Time ([Instant]) in milliseconds of the request
-
hasReplyTopic
boolean hasReplyTopic()
Checks whether the 'replyTopic' field has been set. The topic the response needs to be posted on
-
clearReplyTopic
RPCRequest.Builder clearReplyTopic()
Clears the value of the 'replyTopic' field. The topic the response needs to be posted on
-
hasReplyPartition
boolean hasReplyPartition()
Checks whether the 'replyPartition' field has been set. The partition we expect the response to be on
-
clearReplyPartition
RPCRequest.Builder clearReplyPartition()
Clears the value of the 'replyPartition' field. The partition we expect the response to be on
-
hasPayload
boolean hasPayload()
Checks whether the 'payload' field has been set.
-
clearPayload
RPCRequest.Builder clearPayload()
Clears the value of the 'payload' field.
-
build
RPCRequest build()
-
-
-
-