Class ReliableDelivery.State
- java.lang.Object
-
- org.apache.pekko.protobufv3.internal.AbstractMessageLite
-
- org.apache.pekko.protobufv3.internal.AbstractMessage
-
- org.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
- org.apache.pekko.cluster.typed.internal.protobuf.ReliableDelivery.State
-
- All Implemented Interfaces:
java.io.Serializable,ReliableDelivery.StateOrBuilder,org.apache.pekko.protobufv3.internal.Message,org.apache.pekko.protobufv3.internal.MessageLite,org.apache.pekko.protobufv3.internal.MessageLiteOrBuilder,org.apache.pekko.protobufv3.internal.MessageOrBuilder
- Enclosing class:
- ReliableDelivery
public static final class ReliableDelivery.State extends org.apache.pekko.protobufv3.internal.GeneratedMessageV3 implements ReliableDelivery.StateOrBuilder
DurableProducerQueue
Protobuf typeorg.apache.pekko.cluster.typed.delivery.State- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classReliableDelivery.State.BuilderDurableProducerQueue-
Nested classes/interfaces inherited from class org.apache.pekko.protobufv3.internal.GeneratedMessageV3
org.apache.pekko.protobufv3.internal.GeneratedMessageV3.BuilderParent, org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableBuilder<MessageT extends org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableMessage<MessageT extends org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableMessage<MessageT>>, org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends org.apache.pekko.protobufv3.internal.GeneratedMessageV3.ExtendableMessage<MessageT>>, org.apache.pekko.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable, org.apache.pekko.protobufv3.internal.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intCONFIRMED_FIELD_NUMBERstatic intCURRENTSEQNR_FIELD_NUMBERstatic intHIGHESTCONFIRMEDSEQNR_FIELD_NUMBERstatic org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.State>PARSERDeprecated.static intUNCONFIRMED_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(java.lang.Object obj)ReliableDelivery.ConfirmedgetConfirmed(int index)repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;intgetConfirmedCount()repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;java.util.List<ReliableDelivery.Confirmed>getConfirmedList()repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;ReliableDelivery.ConfirmedOrBuildergetConfirmedOrBuilder(int index)repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;java.util.List<? extends ReliableDelivery.ConfirmedOrBuilder>getConfirmedOrBuilderList()repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;longgetCurrentSeqNr()required int64 currentSeqNr = 1;static ReliableDelivery.StategetDefaultInstance()ReliableDelivery.StategetDefaultInstanceForType()static org.apache.pekko.protobufv3.internal.Descriptors.DescriptorgetDescriptor()longgetHighestConfirmedSeqNr()required int64 highestConfirmedSeqNr = 2;org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.State>getParserForType()intgetSerializedSize()ReliableDelivery.MessageSentgetUnconfirmed(int index)repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;intgetUnconfirmedCount()repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;java.util.List<ReliableDelivery.MessageSent>getUnconfirmedList()repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;ReliableDelivery.MessageSentOrBuildergetUnconfirmedOrBuilder(int index)repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;java.util.List<? extends ReliableDelivery.MessageSentOrBuilder>getUnconfirmedOrBuilderList()repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;org.apache.pekko.protobufv3.internal.UnknownFieldSetgetUnknownFields()booleanhasCurrentSeqNr()required int64 currentSeqNr = 1;inthashCode()booleanhasHighestConfirmedSeqNr()required int64 highestConfirmedSeqNr = 2;protected org.apache.pekko.protobufv3.internal.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static ReliableDelivery.State.BuildernewBuilder()static ReliableDelivery.State.BuildernewBuilder(ReliableDelivery.State prototype)ReliableDelivery.State.BuildernewBuilderForType()protected ReliableDelivery.State.BuildernewBuilderForType(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.BuilderParent parent)protected java.lang.ObjectnewInstance(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.UnusedPrivateParameter unused)static ReliableDelivery.StateparseDelimitedFrom(java.io.InputStream input)static ReliableDelivery.StateparseDelimitedFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.StateparseFrom(byte[] data)static ReliableDelivery.StateparseFrom(byte[] data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.StateparseFrom(java.io.InputStream input)static ReliableDelivery.StateparseFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.StateparseFrom(java.nio.ByteBuffer data)static ReliableDelivery.StateparseFrom(java.nio.ByteBuffer data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.StateparseFrom(org.apache.pekko.protobufv3.internal.ByteString data)static ReliableDelivery.StateparseFrom(org.apache.pekko.protobufv3.internal.ByteString data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.StateparseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input)static ReliableDelivery.StateparseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.State>parser()ReliableDelivery.State.BuildertoBuilder()voidwriteTo(org.apache.pekko.protobufv3.internal.CodedOutputStream output)-
Methods inherited from class org.apache.pekko.protobufv3.internal.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class org.apache.pekko.protobufv3.internal.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class org.apache.pekko.protobufv3.internal.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
CURRENTSEQNR_FIELD_NUMBER
public static final int CURRENTSEQNR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
HIGHESTCONFIRMEDSEQNR_FIELD_NUMBER
public static final int HIGHESTCONFIRMEDSEQNR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
CONFIRMED_FIELD_NUMBER
public static final int CONFIRMED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
UNCONFIRMED_FIELD_NUMBER
public static final int UNCONFIRMED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PARSER
@Deprecated public static final org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.State> PARSER
Deprecated.
-
-
Method Detail
-
newInstance
protected java.lang.Object newInstance(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstancein classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
getUnknownFields
public final org.apache.pekko.protobufv3.internal.UnknownFieldSet getUnknownFields()
- Specified by:
getUnknownFieldsin interfaceorg.apache.pekko.protobufv3.internal.MessageOrBuilder- Overrides:
getUnknownFieldsin classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
getDescriptor
public static final org.apache.pekko.protobufv3.internal.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected org.apache.pekko.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
hasCurrentSeqNr
public boolean hasCurrentSeqNr()
required int64 currentSeqNr = 1;- Specified by:
hasCurrentSeqNrin interfaceReliableDelivery.StateOrBuilder- Returns:
- Whether the currentSeqNr field is set.
-
getCurrentSeqNr
public long getCurrentSeqNr()
required int64 currentSeqNr = 1;- Specified by:
getCurrentSeqNrin interfaceReliableDelivery.StateOrBuilder- Returns:
- The currentSeqNr.
-
hasHighestConfirmedSeqNr
public boolean hasHighestConfirmedSeqNr()
required int64 highestConfirmedSeqNr = 2;- Specified by:
hasHighestConfirmedSeqNrin interfaceReliableDelivery.StateOrBuilder- Returns:
- Whether the highestConfirmedSeqNr field is set.
-
getHighestConfirmedSeqNr
public long getHighestConfirmedSeqNr()
required int64 highestConfirmedSeqNr = 2;- Specified by:
getHighestConfirmedSeqNrin interfaceReliableDelivery.StateOrBuilder- Returns:
- The highestConfirmedSeqNr.
-
getConfirmedList
public java.util.List<ReliableDelivery.Confirmed> getConfirmedList()
repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;- Specified by:
getConfirmedListin interfaceReliableDelivery.StateOrBuilder
-
getConfirmedOrBuilderList
public java.util.List<? extends ReliableDelivery.ConfirmedOrBuilder> getConfirmedOrBuilderList()
repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;- Specified by:
getConfirmedOrBuilderListin interfaceReliableDelivery.StateOrBuilder
-
getConfirmedCount
public int getConfirmedCount()
repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;- Specified by:
getConfirmedCountin interfaceReliableDelivery.StateOrBuilder
-
getConfirmed
public ReliableDelivery.Confirmed getConfirmed(int index)
repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;- Specified by:
getConfirmedin interfaceReliableDelivery.StateOrBuilder
-
getConfirmedOrBuilder
public ReliableDelivery.ConfirmedOrBuilder getConfirmedOrBuilder(int index)
repeated .org.apache.pekko.cluster.typed.delivery.Confirmed confirmed = 3;- Specified by:
getConfirmedOrBuilderin interfaceReliableDelivery.StateOrBuilder
-
getUnconfirmedList
public java.util.List<ReliableDelivery.MessageSent> getUnconfirmedList()
repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;- Specified by:
getUnconfirmedListin interfaceReliableDelivery.StateOrBuilder
-
getUnconfirmedOrBuilderList
public java.util.List<? extends ReliableDelivery.MessageSentOrBuilder> getUnconfirmedOrBuilderList()
repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;- Specified by:
getUnconfirmedOrBuilderListin interfaceReliableDelivery.StateOrBuilder
-
getUnconfirmedCount
public int getUnconfirmedCount()
repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;- Specified by:
getUnconfirmedCountin interfaceReliableDelivery.StateOrBuilder
-
getUnconfirmed
public ReliableDelivery.MessageSent getUnconfirmed(int index)
repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;- Specified by:
getUnconfirmedin interfaceReliableDelivery.StateOrBuilder
-
getUnconfirmedOrBuilder
public ReliableDelivery.MessageSentOrBuilder getUnconfirmedOrBuilder(int index)
repeated .org.apache.pekko.cluster.typed.delivery.MessageSent unconfirmed = 4;- Specified by:
getUnconfirmedOrBuilderin interfaceReliableDelivery.StateOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfaceorg.apache.pekko.protobufv3.internal.MessageLiteOrBuilder- Overrides:
isInitializedin classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
writeTo
public void writeTo(org.apache.pekko.protobufv3.internal.CodedOutputStream output) throws java.io.IOException- Specified by:
writeToin interfaceorg.apache.pekko.protobufv3.internal.MessageLite- Overrides:
writeToin classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3- Throws:
java.io.IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfaceorg.apache.pekko.protobufv3.internal.MessageLite- Overrides:
getSerializedSizein classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
equals
public boolean equals(java.lang.Object obj)
- Specified by:
equalsin interfaceorg.apache.pekko.protobufv3.internal.Message- Overrides:
equalsin classorg.apache.pekko.protobufv3.internal.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfaceorg.apache.pekko.protobufv3.internal.Message- Overrides:
hashCodein classorg.apache.pekko.protobufv3.internal.AbstractMessage
-
parseFrom
public static ReliableDelivery.State parseFrom(java.nio.ByteBuffer data) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.State parseFrom(java.nio.ByteBuffer data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.State parseFrom(org.apache.pekko.protobufv3.internal.ByteString data) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.State parseFrom(org.apache.pekko.protobufv3.internal.ByteString data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.State parseFrom(byte[] data) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.State parseFrom(byte[] data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.State parseFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReliableDelivery.State parseFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ReliableDelivery.State parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ReliableDelivery.State parseDelimitedFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReliableDelivery.State parseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReliableDelivery.State parseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
newBuilderForType
public ReliableDelivery.State.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfaceorg.apache.pekko.protobufv3.internal.Message- Specified by:
newBuilderForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageLite
-
newBuilder
public static ReliableDelivery.State.Builder newBuilder()
-
newBuilder
public static ReliableDelivery.State.Builder newBuilder(ReliableDelivery.State prototype)
-
toBuilder
public ReliableDelivery.State.Builder toBuilder()
- Specified by:
toBuilderin interfaceorg.apache.pekko.protobufv3.internal.Message- Specified by:
toBuilderin interfaceorg.apache.pekko.protobufv3.internal.MessageLite
-
newBuilderForType
protected ReliableDelivery.State.Builder newBuilderForType(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
getDefaultInstance
public static ReliableDelivery.State getDefaultInstance()
-
parser
public static org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.State> parser()
-
getParserForType
public org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.State> getParserForType()
- Specified by:
getParserForTypein interfaceorg.apache.pekko.protobufv3.internal.Message- Specified by:
getParserForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageLite- Overrides:
getParserForTypein classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
getDefaultInstanceForType
public ReliableDelivery.State getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageOrBuilder
-
-