Class SessionProcessState
-
- 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 SessionProcessState extends SpecificRecordBase implements SpecificRecord
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
SessionProcessState.Builder
RecordBuilder for SessionProcessState instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public int
lastProcessedSequenceNum
public List<SessionEvent>
undeliveredMessages
-
Constructor Summary
Constructors Constructor Description SessionProcessState()
Default constructor. SessionProcessState(Integer lastProcessedSequenceNum, List<SessionEvent> undeliveredMessages)
All-args constructor.
-
Method Summary
Modifier and Type Method Description int
getLastProcessedSequenceNum()
Gets the value of the 'lastProcessedSequenceNum' field. void
setLastProcessedSequenceNum(int value)
Sets the value of the 'lastProcessedSequenceNum' field. List<SessionEvent>
getUndeliveredMessages()
Gets the value of the 'undeliveredMessages' field. void
setUndeliveredMessages(List<SessionEvent> value)
Sets the value of the 'undeliveredMessages' field. static Schema
getClassSchema()
static BinaryMessageEncoder<SessionProcessState>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<SessionProcessState>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<SessionProcessState>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this SessionProcessState to a ByteBuffer. static SessionProcessState
fromByteBuffer(ByteBuffer b)
Deserializes a SessionProcessState from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
void
put(int field$, Object value$)
static SessionProcessState.Builder
newBuilder()
Creates a new SessionProcessState RecordBuilder. static SessionProcessState.Builder
newBuilder(SessionProcessState.Builder other)
Creates a new SessionProcessState RecordBuilder by copying an existing Builder. static SessionProcessState.Builder
newBuilder(SessionProcessState other)
Creates a new SessionProcessState RecordBuilder by copying an existing SessionProcessState instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, getConversion, hashCode, toString
-
Methods inherited from class org.apache.avro.generic.GenericRecord
hasField
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
SessionProcessState
SessionProcessState()
Default constructor.
-
SessionProcessState
SessionProcessState(Integer lastProcessedSequenceNum, List<SessionEvent> undeliveredMessages)
All-args constructor.- Parameters:
lastProcessedSequenceNum
- The sequence number of the last message in the unbroken contiguous sequence of previous messages.undeliveredMessages
- The list of messages not confirmed as delivered.
-
-
Method Detail
-
getLastProcessedSequenceNum
int getLastProcessedSequenceNum()
Gets the value of the 'lastProcessedSequenceNum' field.
-
setLastProcessedSequenceNum
void 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 to set.
-
getUndeliveredMessages
List<SessionEvent> getUndeliveredMessages()
Gets the value of the 'undeliveredMessages' field.
-
setUndeliveredMessages
void 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 to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<SessionProcessState> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<SessionProcessState> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<SessionProcessState> createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
- Parameters:
resolver
- a SchemaStore used to find schemas by fingerprint
-
toByteBuffer
ByteBuffer toByteBuffer()
Serializes this SessionProcessState to a ByteBuffer.
-
fromByteBuffer
static SessionProcessState fromByteBuffer(ByteBuffer b)
Deserializes a SessionProcessState from a ByteBuffer.
- Parameters:
b
- a byte buffer holding serialized data for an instance of this class
-
getSpecificData
SpecificData getSpecificData()
-
getSchema
Schema getSchema()
-
newBuilder
static SessionProcessState.Builder newBuilder()
Creates a new SessionProcessState RecordBuilder.
-
newBuilder
static SessionProcessState.Builder newBuilder(SessionProcessState.Builder other)
Creates a new SessionProcessState RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static SessionProcessState.Builder newBuilder(SessionProcessState other)
Creates a new SessionProcessState RecordBuilder by copying an existing SessionProcessState instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
-
-
-