Package akka.persistence.serialization
Class MessageFormats.PersistentMessage
- java.lang.Object
-
- akka.protobuf.AbstractMessageLite
-
- akka.protobuf.AbstractMessage
-
- akka.protobuf.GeneratedMessage
-
- akka.persistence.serialization.MessageFormats.PersistentMessage
-
- All Implemented Interfaces:
MessageFormats.PersistentMessageOrBuilder
,akka.protobuf.Message
,akka.protobuf.MessageLite
,akka.protobuf.MessageLiteOrBuilder
,akka.protobuf.MessageOrBuilder
,java.io.Serializable
- Enclosing class:
- MessageFormats
public static final class MessageFormats.PersistentMessage extends akka.protobuf.GeneratedMessage implements MessageFormats.PersistentMessageOrBuilder
Protobuf typePersistentMessage
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
MessageFormats.PersistentMessage.Builder
Protobuf typePersistentMessage
-
Nested classes/interfaces inherited from class akka.protobuf.GeneratedMessage
akka.protobuf.GeneratedMessage.BuilderParent, akka.protobuf.GeneratedMessage.ExtendableBuilder<MessageType extends akka.protobuf.GeneratedMessage.ExtendableMessage,BuilderType extends akka.protobuf.GeneratedMessage.ExtendableBuilder>, akka.protobuf.GeneratedMessage.ExtendableMessage<MessageType extends akka.protobuf.GeneratedMessage.ExtendableMessage>, akka.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageType extends akka.protobuf.GeneratedMessage.ExtendableMessage>, akka.protobuf.GeneratedMessage.FieldAccessorTable, akka.protobuf.GeneratedMessage.GeneratedExtension<ContainingType extends akka.protobuf.Message,Type extends java.lang.Object>
-
-
Field Summary
Fields Modifier and Type Field Description static int
DELETED_FIELD_NUMBER
static int
MANIFEST_FIELD_NUMBER
static akka.protobuf.Parser<MessageFormats.PersistentMessage>
PARSER
static int
PAYLOAD_FIELD_NUMBER
static int
PERSISTENCEID_FIELD_NUMBER
static int
SENDER_FIELD_NUMBER
static int
SEQUENCENR_FIELD_NUMBER
static int
TIMESTAMP_FIELD_NUMBER
static int
WRITERUUID_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static MessageFormats.PersistentMessage
getDefaultInstance()
MessageFormats.PersistentMessage
getDefaultInstanceForType()
boolean
getDeleted()
optional bool deleted = 4;
static akka.protobuf.Descriptors.Descriptor
getDescriptor()
java.lang.String
getManifest()
optional string manifest = 12;
akka.protobuf.ByteString
getManifestBytes()
optional string manifest = 12;
akka.protobuf.Parser<MessageFormats.PersistentMessage>
getParserForType()
MessageFormats.PersistentPayload
getPayload()
optional .PersistentPayload payload = 1;
MessageFormats.PersistentPayloadOrBuilder
getPayloadOrBuilder()
optional .PersistentPayload payload = 1;
java.lang.String
getPersistenceId()
optional string persistenceId = 3;
akka.protobuf.ByteString
getPersistenceIdBytes()
optional string persistenceId = 3;
java.lang.String
getSender()
optional string sender = 11;
akka.protobuf.ByteString
getSenderBytes()
optional string sender = 11;
long
getSequenceNr()
optional int64 sequenceNr = 2;
int
getSerializedSize()
long
getTimestamp()
optional sint64 timestamp = 14;
akka.protobuf.UnknownFieldSet
getUnknownFields()
java.lang.String
getWriterUuid()
optional string writerUuid = 13;
akka.protobuf.ByteString
getWriterUuidBytes()
optional string writerUuid = 13;
boolean
hasDeleted()
optional bool deleted = 4;
boolean
hasManifest()
optional string manifest = 12;
boolean
hasPayload()
optional .PersistentPayload payload = 1;
boolean
hasPersistenceId()
optional string persistenceId = 3;
boolean
hasSender()
optional string sender = 11;
boolean
hasSequenceNr()
optional int64 sequenceNr = 2;
boolean
hasTimestamp()
optional sint64 timestamp = 14;
boolean
hasWriterUuid()
optional string writerUuid = 13;
protected akka.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static MessageFormats.PersistentMessage.Builder
newBuilder()
static MessageFormats.PersistentMessage.Builder
newBuilder(MessageFormats.PersistentMessage prototype)
MessageFormats.PersistentMessage.Builder
newBuilderForType()
protected MessageFormats.PersistentMessage.Builder
newBuilderForType(akka.protobuf.GeneratedMessage.BuilderParent parent)
static MessageFormats.PersistentMessage
parseDelimitedFrom(java.io.InputStream input)
static MessageFormats.PersistentMessage
parseDelimitedFrom(java.io.InputStream input, akka.protobuf.ExtensionRegistryLite extensionRegistry)
static MessageFormats.PersistentMessage
parseFrom(byte[] data)
static MessageFormats.PersistentMessage
parseFrom(byte[] data, akka.protobuf.ExtensionRegistryLite extensionRegistry)
static MessageFormats.PersistentMessage
parseFrom(akka.protobuf.ByteString data)
static MessageFormats.PersistentMessage
parseFrom(akka.protobuf.ByteString data, akka.protobuf.ExtensionRegistryLite extensionRegistry)
static MessageFormats.PersistentMessage
parseFrom(akka.protobuf.CodedInputStream input)
static MessageFormats.PersistentMessage
parseFrom(akka.protobuf.CodedInputStream input, akka.protobuf.ExtensionRegistryLite extensionRegistry)
static MessageFormats.PersistentMessage
parseFrom(java.io.InputStream input)
static MessageFormats.PersistentMessage
parseFrom(java.io.InputStream input, akka.protobuf.ExtensionRegistryLite extensionRegistry)
MessageFormats.PersistentMessage.Builder
toBuilder()
protected java.lang.Object
writeReplace()
void
writeTo(akka.protobuf.CodedOutputStream output)
-
Methods inherited from class akka.protobuf.GeneratedMessage
getAllFields, getDescriptorForType, getField, getRepeatedField, getRepeatedFieldCount, hasField, makeExtensionsImmutable, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension, parseUnknownField
-
Methods inherited from class akka.protobuf.AbstractMessage
equals, findInitializationErrors, getInitializationErrorString, hashBoolean, hashCode, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class akka.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
PARSER
public static akka.protobuf.Parser<MessageFormats.PersistentMessage> PARSER
-
PAYLOAD_FIELD_NUMBER
public static final int PAYLOAD_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SEQUENCENR_FIELD_NUMBER
public static final int SEQUENCENR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PERSISTENCEID_FIELD_NUMBER
public static final int PERSISTENCEID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DELETED_FIELD_NUMBER
public static final int DELETED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SENDER_FIELD_NUMBER
public static final int SENDER_FIELD_NUMBER
- See Also:
- Constant Field Values
-
MANIFEST_FIELD_NUMBER
public static final int MANIFEST_FIELD_NUMBER
- See Also:
- Constant Field Values
-
WRITERUUID_FIELD_NUMBER
public static final int WRITERUUID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TIMESTAMP_FIELD_NUMBER
public static final int TIMESTAMP_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
getDefaultInstance
public static MessageFormats.PersistentMessage getDefaultInstance()
-
getDefaultInstanceForType
public MessageFormats.PersistentMessage getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfaceakka.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfaceakka.protobuf.MessageOrBuilder
-
getUnknownFields
public final akka.protobuf.UnknownFieldSet getUnknownFields()
- Specified by:
getUnknownFields
in interfaceakka.protobuf.MessageOrBuilder
- Overrides:
getUnknownFields
in classakka.protobuf.GeneratedMessage
-
getDescriptor
public static final akka.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected akka.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classakka.protobuf.GeneratedMessage
-
getParserForType
public akka.protobuf.Parser<MessageFormats.PersistentMessage> getParserForType()
- Specified by:
getParserForType
in interfaceakka.protobuf.Message
- Specified by:
getParserForType
in interfaceakka.protobuf.MessageLite
- Overrides:
getParserForType
in classakka.protobuf.GeneratedMessage
-
hasPayload
public boolean hasPayload()
optional .PersistentPayload payload = 1;
- Specified by:
hasPayload
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getPayload
public MessageFormats.PersistentPayload getPayload()
optional .PersistentPayload payload = 1;
- Specified by:
getPayload
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getPayloadOrBuilder
public MessageFormats.PersistentPayloadOrBuilder getPayloadOrBuilder()
optional .PersistentPayload payload = 1;
- Specified by:
getPayloadOrBuilder
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasSequenceNr
public boolean hasSequenceNr()
optional int64 sequenceNr = 2;
- Specified by:
hasSequenceNr
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getSequenceNr
public long getSequenceNr()
optional int64 sequenceNr = 2;
- Specified by:
getSequenceNr
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasPersistenceId
public boolean hasPersistenceId()
optional string persistenceId = 3;
- Specified by:
hasPersistenceId
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getPersistenceId
public java.lang.String getPersistenceId()
optional string persistenceId = 3;
- Specified by:
getPersistenceId
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getPersistenceIdBytes
public akka.protobuf.ByteString getPersistenceIdBytes()
optional string persistenceId = 3;
- Specified by:
getPersistenceIdBytes
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasDeleted
public boolean hasDeleted()
optional bool deleted = 4;
not used in new records from 2.4
- Specified by:
hasDeleted
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getDeleted
public boolean getDeleted()
optional bool deleted = 4;
not used in new records from 2.4
- Specified by:
getDeleted
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasSender
public boolean hasSender()
optional string sender = 11;
optional int32 redeliveries = 6; // Removed in 2.4 repeated string confirms = 7; // Removed in 2.4 optional bool confirmable = 8; // Removed in 2.4 optional DeliveredMessage confirmMessage = 9; // Removed in 2.4 optional string confirmTarget = 10; // Removed in 2.4
- Specified by:
hasSender
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getSender
public java.lang.String getSender()
optional string sender = 11;
optional int32 redeliveries = 6; // Removed in 2.4 repeated string confirms = 7; // Removed in 2.4 optional bool confirmable = 8; // Removed in 2.4 optional DeliveredMessage confirmMessage = 9; // Removed in 2.4 optional string confirmTarget = 10; // Removed in 2.4
- Specified by:
getSender
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getSenderBytes
public akka.protobuf.ByteString getSenderBytes()
optional string sender = 11;
optional int32 redeliveries = 6; // Removed in 2.4 repeated string confirms = 7; // Removed in 2.4 optional bool confirmable = 8; // Removed in 2.4 optional DeliveredMessage confirmMessage = 9; // Removed in 2.4 optional string confirmTarget = 10; // Removed in 2.4
- Specified by:
getSenderBytes
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasManifest
public boolean hasManifest()
optional string manifest = 12;
- Specified by:
hasManifest
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getManifest
public java.lang.String getManifest()
optional string manifest = 12;
- Specified by:
getManifest
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getManifestBytes
public akka.protobuf.ByteString getManifestBytes()
optional string manifest = 12;
- Specified by:
getManifestBytes
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasWriterUuid
public boolean hasWriterUuid()
optional string writerUuid = 13;
- Specified by:
hasWriterUuid
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getWriterUuid
public java.lang.String getWriterUuid()
optional string writerUuid = 13;
- Specified by:
getWriterUuid
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getWriterUuidBytes
public akka.protobuf.ByteString getWriterUuidBytes()
optional string writerUuid = 13;
- Specified by:
getWriterUuidBytes
in interfaceMessageFormats.PersistentMessageOrBuilder
-
hasTimestamp
public boolean hasTimestamp()
optional sint64 timestamp = 14;
- Specified by:
hasTimestamp
in interfaceMessageFormats.PersistentMessageOrBuilder
-
getTimestamp
public long getTimestamp()
optional sint64 timestamp = 14;
- Specified by:
getTimestamp
in interfaceMessageFormats.PersistentMessageOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfaceakka.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classakka.protobuf.GeneratedMessage
-
writeTo
public void writeTo(akka.protobuf.CodedOutputStream output) throws java.io.IOException
- Specified by:
writeTo
in interfaceakka.protobuf.MessageLite
- Overrides:
writeTo
in classakka.protobuf.AbstractMessage
- Throws:
java.io.IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfaceakka.protobuf.MessageLite
- Overrides:
getSerializedSize
in classakka.protobuf.AbstractMessage
-
writeReplace
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Overrides:
writeReplace
in classakka.protobuf.GeneratedMessage
- Throws:
java.io.ObjectStreamException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(akka.protobuf.ByteString data) throws akka.protobuf.InvalidProtocolBufferException
- Throws:
akka.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(akka.protobuf.ByteString data, akka.protobuf.ExtensionRegistryLite extensionRegistry) throws akka.protobuf.InvalidProtocolBufferException
- Throws:
akka.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(byte[] data) throws akka.protobuf.InvalidProtocolBufferException
- Throws:
akka.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(byte[] data, akka.protobuf.ExtensionRegistryLite extensionRegistry) throws akka.protobuf.InvalidProtocolBufferException
- Throws:
akka.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(java.io.InputStream input, akka.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static MessageFormats.PersistentMessage parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static MessageFormats.PersistentMessage parseDelimitedFrom(java.io.InputStream input, akka.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(akka.protobuf.CodedInputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static MessageFormats.PersistentMessage parseFrom(akka.protobuf.CodedInputStream input, akka.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
newBuilder
public static MessageFormats.PersistentMessage.Builder newBuilder()
-
newBuilderForType
public MessageFormats.PersistentMessage.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfaceakka.protobuf.Message
- Specified by:
newBuilderForType
in interfaceakka.protobuf.MessageLite
-
newBuilder
public static MessageFormats.PersistentMessage.Builder newBuilder(MessageFormats.PersistentMessage prototype)
-
toBuilder
public MessageFormats.PersistentMessage.Builder toBuilder()
- Specified by:
toBuilder
in interfaceakka.protobuf.Message
- Specified by:
toBuilder
in interfaceakka.protobuf.MessageLite
-
newBuilderForType
protected MessageFormats.PersistentMessage.Builder newBuilderForType(akka.protobuf.GeneratedMessage.BuilderParent parent)
- Specified by:
newBuilderForType
in classakka.protobuf.GeneratedMessage
-
-