Class SessionProcessState.Builder
-
- All Implemented Interfaces:
-
org.apache.avro.data.RecordBuilder
public class SessionProcessState.Builder extends SpecificRecordBuilderBase<T> implements RecordBuilder<T>
RecordBuilder for SessionProcessState instances.
-
-
Field Summary
Fields Modifier and Type Field Description public int
lastProcessedSequenceNum
public List<SessionEvent>
undeliveredMessages
-
Method Summary
Modifier and Type Method Description int
getLastProcessedSequenceNum()
Gets the value of the 'lastProcessedSequenceNum' field. SessionProcessState.Builder
setLastProcessedSequenceNum(int value)
Sets the value of the 'lastProcessedSequenceNum' field. List<SessionEvent>
getUndeliveredMessages()
Gets the value of the 'undeliveredMessages' field. SessionProcessState.Builder
setUndeliveredMessages(List<SessionEvent> value)
Sets the value of the 'undeliveredMessages' field. boolean
hasLastProcessedSequenceNum()
Checks whether the 'lastProcessedSequenceNum' field has been set. SessionProcessState.Builder
clearLastProcessedSequenceNum()
Clears the value of the 'lastProcessedSequenceNum' field. boolean
hasUndeliveredMessages()
Checks whether the 'undeliveredMessages' field has been set. SessionProcessState.Builder
clearUndeliveredMessages()
Clears the value of the 'undeliveredMessages' field. SessionProcessState
build()
-
-
Method Detail
-
getLastProcessedSequenceNum
int getLastProcessedSequenceNum()
Gets the value of the 'lastProcessedSequenceNum' field. The sequence number of the last message in the unbroken contiguous sequence of previous messages. undeliveredMessages can contain messages which sequence numbers greater than this.
-
setLastProcessedSequenceNum
SessionProcessState.Builder setLastProcessedSequenceNum(int value)
Sets the value of the 'lastProcessedSequenceNum' field. The sequence number of the last message in the unbroken contiguous sequence of previous messages. undeliveredMessages can contain messages which sequence numbers greater than this.
- Parameters:
value
- The value of 'lastProcessedSequenceNum'.
-
getUndeliveredMessages
List<SessionEvent> getUndeliveredMessages()
Gets the value of the 'undeliveredMessages' field. The list of messages not confirmed as delivered. For outbound messages these are non-acked events. For inbound events these are events not yet processed by the client lib and/or of order messages.
-
setUndeliveredMessages
SessionProcessState.Builder setUndeliveredMessages(List<SessionEvent> value)
Sets the value of the 'undeliveredMessages' field. The list of messages not confirmed as delivered. For outbound messages these are non-acked events. For inbound events these are events not yet processed by the client lib and/or of order messages.
- Parameters:
value
- The value of 'undeliveredMessages'.
-
hasLastProcessedSequenceNum
boolean hasLastProcessedSequenceNum()
Checks whether the 'lastProcessedSequenceNum' field has been set. The sequence number of the last message in the unbroken contiguous sequence of previous messages. undeliveredMessages can contain messages which sequence numbers greater than this.
-
clearLastProcessedSequenceNum
SessionProcessState.Builder clearLastProcessedSequenceNum()
Clears the value of the 'lastProcessedSequenceNum' field. The sequence number of the last message in the unbroken contiguous sequence of previous messages. undeliveredMessages can contain messages which sequence numbers greater than this.
-
hasUndeliveredMessages
boolean hasUndeliveredMessages()
Checks whether the 'undeliveredMessages' field has been set. The list of messages not confirmed as delivered. For outbound messages these are non-acked events. For inbound events these are events not yet processed by the client lib and/or of order messages.
-
clearUndeliveredMessages
SessionProcessState.Builder clearUndeliveredMessages()
Clears the value of the 'undeliveredMessages' field. The list of messages not confirmed as delivered. For outbound messages these are non-acked events. For inbound events these are events not yet processed by the client lib and/or of order messages.
-
build
SessionProcessState build()
-
-
-
-