Class ReliableDelivery.Request
- 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.Request
-
- All Implemented Interfaces:
java.io.Serializable,ReliableDelivery.RequestOrBuilder,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.Request extends org.apache.pekko.protobufv3.internal.GeneratedMessageV3 implements ReliableDelivery.RequestOrBuilder
ProducerController
Protobuf typeorg.apache.pekko.cluster.typed.delivery.Request- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classReliableDelivery.Request.BuilderProducerController-
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 intCONFIRMEDSEQNR_FIELD_NUMBERstatic org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.Request>PARSERDeprecated.static intREQUESTUPTOSEQNR_FIELD_NUMBERstatic intSUPPORTRESEND_FIELD_NUMBERstatic intVIATIMEOUT_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(java.lang.Object obj)longgetConfirmedSeqNr()required int64 confirmedSeqNr = 1;static ReliableDelivery.RequestgetDefaultInstance()ReliableDelivery.RequestgetDefaultInstanceForType()static org.apache.pekko.protobufv3.internal.Descriptors.DescriptorgetDescriptor()org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.Request>getParserForType()longgetRequestUpToSeqNr()required int64 requestUpToSeqNr = 2;intgetSerializedSize()booleangetSupportResend()required bool supportResend = 3;org.apache.pekko.protobufv3.internal.UnknownFieldSetgetUnknownFields()booleangetViaTimeout()required bool viaTimeout = 4;booleanhasConfirmedSeqNr()required int64 confirmedSeqNr = 1;inthashCode()booleanhasRequestUpToSeqNr()required int64 requestUpToSeqNr = 2;booleanhasSupportResend()required bool supportResend = 3;booleanhasViaTimeout()required bool viaTimeout = 4;protected org.apache.pekko.protobufv3.internal.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static ReliableDelivery.Request.BuildernewBuilder()static ReliableDelivery.Request.BuildernewBuilder(ReliableDelivery.Request prototype)ReliableDelivery.Request.BuildernewBuilderForType()protected ReliableDelivery.Request.BuildernewBuilderForType(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.BuilderParent parent)protected java.lang.ObjectnewInstance(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.UnusedPrivateParameter unused)static ReliableDelivery.RequestparseDelimitedFrom(java.io.InputStream input)static ReliableDelivery.RequestparseDelimitedFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.RequestparseFrom(byte[] data)static ReliableDelivery.RequestparseFrom(byte[] data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.RequestparseFrom(java.io.InputStream input)static ReliableDelivery.RequestparseFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.RequestparseFrom(java.nio.ByteBuffer data)static ReliableDelivery.RequestparseFrom(java.nio.ByteBuffer data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.RequestparseFrom(org.apache.pekko.protobufv3.internal.ByteString data)static ReliableDelivery.RequestparseFrom(org.apache.pekko.protobufv3.internal.ByteString data, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static ReliableDelivery.RequestparseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input)static ReliableDelivery.RequestparseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry)static org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.Request>parser()ReliableDelivery.Request.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
-
CONFIRMEDSEQNR_FIELD_NUMBER
public static final int CONFIRMEDSEQNR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
REQUESTUPTOSEQNR_FIELD_NUMBER
public static final int REQUESTUPTOSEQNR_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SUPPORTRESEND_FIELD_NUMBER
public static final int SUPPORTRESEND_FIELD_NUMBER
- See Also:
- Constant Field Values
-
VIATIMEOUT_FIELD_NUMBER
public static final int VIATIMEOUT_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PARSER
@Deprecated public static final org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.Request> 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
-
hasConfirmedSeqNr
public boolean hasConfirmedSeqNr()
required int64 confirmedSeqNr = 1;- Specified by:
hasConfirmedSeqNrin interfaceReliableDelivery.RequestOrBuilder- Returns:
- Whether the confirmedSeqNr field is set.
-
getConfirmedSeqNr
public long getConfirmedSeqNr()
required int64 confirmedSeqNr = 1;- Specified by:
getConfirmedSeqNrin interfaceReliableDelivery.RequestOrBuilder- Returns:
- The confirmedSeqNr.
-
hasRequestUpToSeqNr
public boolean hasRequestUpToSeqNr()
required int64 requestUpToSeqNr = 2;- Specified by:
hasRequestUpToSeqNrin interfaceReliableDelivery.RequestOrBuilder- Returns:
- Whether the requestUpToSeqNr field is set.
-
getRequestUpToSeqNr
public long getRequestUpToSeqNr()
required int64 requestUpToSeqNr = 2;- Specified by:
getRequestUpToSeqNrin interfaceReliableDelivery.RequestOrBuilder- Returns:
- The requestUpToSeqNr.
-
hasSupportResend
public boolean hasSupportResend()
required bool supportResend = 3;- Specified by:
hasSupportResendin interfaceReliableDelivery.RequestOrBuilder- Returns:
- Whether the supportResend field is set.
-
getSupportResend
public boolean getSupportResend()
required bool supportResend = 3;- Specified by:
getSupportResendin interfaceReliableDelivery.RequestOrBuilder- Returns:
- The supportResend.
-
hasViaTimeout
public boolean hasViaTimeout()
required bool viaTimeout = 4;- Specified by:
hasViaTimeoutin interfaceReliableDelivery.RequestOrBuilder- Returns:
- Whether the viaTimeout field is set.
-
getViaTimeout
public boolean getViaTimeout()
required bool viaTimeout = 4;- Specified by:
getViaTimeoutin interfaceReliableDelivery.RequestOrBuilder- Returns:
- The viaTimeout.
-
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.Request parseFrom(java.nio.ByteBuffer data) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.Request 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.Request 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.Request 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.Request parseFrom(byte[] data) throws org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
- Throws:
org.apache.pekko.protobufv3.internal.InvalidProtocolBufferException
-
parseFrom
public static ReliableDelivery.Request 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.Request parseFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReliableDelivery.Request parseFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ReliableDelivery.Request parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ReliableDelivery.Request parseDelimitedFrom(java.io.InputStream input, org.apache.pekko.protobufv3.internal.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReliableDelivery.Request parseFrom(org.apache.pekko.protobufv3.internal.CodedInputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReliableDelivery.Request 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.Request.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfaceorg.apache.pekko.protobufv3.internal.Message- Specified by:
newBuilderForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageLite
-
newBuilder
public static ReliableDelivery.Request.Builder newBuilder()
-
newBuilder
public static ReliableDelivery.Request.Builder newBuilder(ReliableDelivery.Request prototype)
-
toBuilder
public ReliableDelivery.Request.Builder toBuilder()
- Specified by:
toBuilderin interfaceorg.apache.pekko.protobufv3.internal.Message- Specified by:
toBuilderin interfaceorg.apache.pekko.protobufv3.internal.MessageLite
-
newBuilderForType
protected ReliableDelivery.Request.Builder newBuilderForType(org.apache.pekko.protobufv3.internal.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classorg.apache.pekko.protobufv3.internal.GeneratedMessageV3
-
getDefaultInstance
public static ReliableDelivery.Request getDefaultInstance()
-
parser
public static org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.Request> parser()
-
getParserForType
public org.apache.pekko.protobufv3.internal.Parser<ReliableDelivery.Request> 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.Request getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfaceorg.apache.pekko.protobufv3.internal.MessageOrBuilder
-
-