Class RegistrationState
-
- 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 RegistrationState extends SpecificRecordBase implements SpecificRecord
State for a registration.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
RegistrationState.Builder
RecordBuilder for RegistrationState instances.
-
Field Summary
Fields Modifier and Type Field Description public final static Schema
SCHEMA$
public String
registrationId
public HoldingIdentity
registeringMember
public HoldingIdentity
mgm
public List<CompletedCommandMetadata>
previouslyCompletedCommands
-
Constructor Summary
Constructors Constructor Description RegistrationState()
Default constructor. RegistrationState(String registrationId, HoldingIdentity registeringMember, HoldingIdentity mgm, List<CompletedCommandMetadata> previouslyCompletedCommands)
All-args constructor.
-
Method Summary
Modifier and Type Method Description String
getRegistrationId()
Gets the value of the 'registrationId' field. void
setRegistrationId(String value)
Sets the value of the 'registrationId' field. HoldingIdentity
getRegisteringMember()
Gets the value of the 'registeringMember' field. void
setRegisteringMember(HoldingIdentity value)
Sets the value of the 'registeringMember' field. HoldingIdentity
getMgm()
Gets the value of the 'mgm' field. void
setMgm(HoldingIdentity value)
Sets the value of the 'mgm' field. List<CompletedCommandMetadata>
getPreviouslyCompletedCommands()
Gets the value of the 'previouslyCompletedCommands' field. void
setPreviouslyCompletedCommands(List<CompletedCommandMetadata> value)
Sets the value of the 'previouslyCompletedCommands' field. static Schema
getClassSchema()
static BinaryMessageEncoder<RegistrationState>
getEncoder()
Return the BinaryMessageEncoder instance used by this class. static BinaryMessageDecoder<RegistrationState>
getDecoder()
Return the BinaryMessageDecoder instance used by this class. static BinaryMessageDecoder<RegistrationState>
createDecoder(SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore. ByteBuffer
toByteBuffer()
Serializes this RegistrationState to a ByteBuffer. static RegistrationState
fromByteBuffer(ByteBuffer b)
Deserializes a RegistrationState from a ByteBuffer. SpecificData
getSpecificData()
Schema
getSchema()
Object
get(int field$)
Conversion<out Object>
getConversion(int field)
void
put(int field$, Object value$)
static RegistrationState.Builder
newBuilder()
Creates a new RegistrationState RecordBuilder. static RegistrationState.Builder
newBuilder(RegistrationState.Builder other)
Creates a new RegistrationState RecordBuilder by copying an existing Builder. static RegistrationState.Builder
newBuilder(RegistrationState other)
Creates a new RegistrationState RecordBuilder by copying an existing RegistrationState instance. void
writeExternal(ObjectOutput out)
void
readExternal(ObjectInput in)
-
Methods inherited from class org.apache.avro.specific.SpecificRecordBase
compareTo, customDecode, customEncode, equals, 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
-
RegistrationState
RegistrationState()
Default constructor.
-
RegistrationState
RegistrationState(String registrationId, HoldingIdentity registeringMember, HoldingIdentity mgm, List<CompletedCommandMetadata> previouslyCompletedCommands)
All-args constructor.- Parameters:
registrationId
- UUID identifying this registration requestregisteringMember
- Holding identity of the registering member as provided during P2P communication.mgm
- Holding identity of the MGM.previouslyCompletedCommands
- A list of all the previously completed commands during registration.
-
-
Method Detail
-
getRegistrationId
String getRegistrationId()
Gets the value of the 'registrationId' field.
-
setRegistrationId
void setRegistrationId(String value)
Sets the value of the 'registrationId' field. UUID identifying this registration request
- Parameters:
value
- the value to set.
-
getRegisteringMember
HoldingIdentity getRegisteringMember()
Gets the value of the 'registeringMember' field.
-
setRegisteringMember
void setRegisteringMember(HoldingIdentity value)
Sets the value of the 'registeringMember' field. Holding identity of the registering member as provided during P2P communication. Used to verify the registration request.
- Parameters:
value
- the value to set.
-
getMgm
HoldingIdentity getMgm()
Gets the value of the 'mgm' field.
-
setMgm
void setMgm(HoldingIdentity value)
Sets the value of the 'mgm' field. Holding identity of the MGM.
- Parameters:
value
- the value to set.
-
getPreviouslyCompletedCommands
List<CompletedCommandMetadata> getPreviouslyCompletedCommands()
Gets the value of the 'previouslyCompletedCommands' field.
-
setPreviouslyCompletedCommands
void setPreviouslyCompletedCommands(List<CompletedCommandMetadata> value)
Sets the value of the 'previouslyCompletedCommands' field. A list of all the previously completed commands during registration. Can be used for idempotency in the case of message replays.
- Parameters:
value
- the value to set.
-
getClassSchema
static Schema getClassSchema()
-
getEncoder
static BinaryMessageEncoder<RegistrationState> getEncoder()
Return the BinaryMessageEncoder instance used by this class.
-
getDecoder
static BinaryMessageDecoder<RegistrationState> getDecoder()
Return the BinaryMessageDecoder instance used by this class.
-
createDecoder
static BinaryMessageDecoder<RegistrationState> 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 RegistrationState to a ByteBuffer.
-
fromByteBuffer
static RegistrationState fromByteBuffer(ByteBuffer b)
Deserializes a RegistrationState from a ByteBuffer.
- Parameters:
b
- a byte buffer holding serialized data for an instance of this class
-
getSpecificData
SpecificData getSpecificData()
-
getSchema
Schema getSchema()
-
getConversion
Conversion<out Object> getConversion(int field)
-
newBuilder
static RegistrationState.Builder newBuilder()
Creates a new RegistrationState RecordBuilder.
-
newBuilder
static RegistrationState.Builder newBuilder(RegistrationState.Builder other)
Creates a new RegistrationState RecordBuilder by copying an existing Builder.
- Parameters:
other
- The existing builder to copy.
-
newBuilder
static RegistrationState.Builder newBuilder(RegistrationState other)
Creates a new RegistrationState RecordBuilder by copying an existing RegistrationState instance.
- Parameters:
other
- The existing instance to copy.
-
writeExternal
void writeExternal(ObjectOutput out)
-
readExternal
void readExternal(ObjectInput in)
-
-
-
-