public final class ReceivedMessage extends com.google.protobuf.GeneratedMessageV3 implements ReceivedMessageOrBuilder
A message and its corresponding acknowledgment ID.Protobuf type
google.pubsub.v1.ReceivedMessage
Modifier and Type | Class and Description |
---|---|
static class |
ReceivedMessage.Builder
A message and its corresponding acknowledgment ID.
|
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
Modifier and Type | Field and Description |
---|---|
static int |
ACK_ID_FIELD_NUMBER |
static int |
DELIVERY_ATTEMPT_FIELD_NUMBER |
static int |
MESSAGE_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
String |
getAckId()
This ID can be used to acknowledge the received message.
|
com.google.protobuf.ByteString |
getAckIdBytes()
This ID can be used to acknowledge the received message.
|
static ReceivedMessage |
getDefaultInstance() |
ReceivedMessage |
getDefaultInstanceForType() |
int |
getDeliveryAttempt()
The approximate number of times that Cloud Pub/Sub has attempted to deliver
the associated message to a subscriber.
|
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
PubsubMessage |
getMessage()
The message.
|
PubsubMessageOrBuilder |
getMessageOrBuilder()
The message.
|
com.google.protobuf.Parser<ReceivedMessage> |
getParserForType() |
int |
getSerializedSize() |
int |
hashCode() |
boolean |
hasMessage()
The message.
|
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static ReceivedMessage.Builder |
newBuilder() |
static ReceivedMessage.Builder |
newBuilder(ReceivedMessage prototype) |
ReceivedMessage.Builder |
newBuilderForType() |
protected ReceivedMessage.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
protected Object |
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused) |
static ReceivedMessage |
parseDelimitedFrom(InputStream input) |
static ReceivedMessage |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReceivedMessage |
parseFrom(byte[] data) |
static ReceivedMessage |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReceivedMessage |
parseFrom(ByteBuffer data) |
static ReceivedMessage |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReceivedMessage |
parseFrom(com.google.protobuf.ByteString data) |
static ReceivedMessage |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReceivedMessage |
parseFrom(com.google.protobuf.CodedInputStream input) |
static ReceivedMessage |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static ReceivedMessage |
parseFrom(InputStream input) |
static ReceivedMessage |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<ReceivedMessage> |
parser() |
ReceivedMessage.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, 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
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final int ACK_ID_FIELD_NUMBER
public static final int MESSAGE_FIELD_NUMBER
public static final int DELIVERY_ATTEMPT_FIELD_NUMBER
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
newInstance
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3
public String getAckId()
This ID can be used to acknowledge the received message.
string ack_id = 1;
getAckId
in interface ReceivedMessageOrBuilder
public com.google.protobuf.ByteString getAckIdBytes()
This ID can be used to acknowledge the received message.
string ack_id = 1;
getAckIdBytes
in interface ReceivedMessageOrBuilder
public boolean hasMessage()
The message.
.google.pubsub.v1.PubsubMessage message = 2;
hasMessage
in interface ReceivedMessageOrBuilder
public PubsubMessage getMessage()
The message.
.google.pubsub.v1.PubsubMessage message = 2;
getMessage
in interface ReceivedMessageOrBuilder
public PubsubMessageOrBuilder getMessageOrBuilder()
The message.
.google.pubsub.v1.PubsubMessage message = 2;
getMessageOrBuilder
in interface ReceivedMessageOrBuilder
public int getDeliveryAttempt()
The approximate number of times that Cloud Pub/Sub has attempted to deliver the associated message to a subscriber. More precisely, this is 1 + (number of NACKs) + (number of ack_deadline exceeds) for this message. A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline exceeds event is whenever a message is not acknowledged within ack_deadline. Note that ack_deadline is initially Subscription.ackDeadlineSeconds, but may get extended automatically by the client library. Upon the first delivery of a given message, `delivery_attempt` will have a value of 1. The value is calculated at best effort and is approximate. If a DeadLetterPolicy is not set on the subscription, this will be 0.
int32 delivery_attempt = 3;
getDeliveryAttempt
in interface ReceivedMessageOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static ReceivedMessage parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ReceivedMessage parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ReceivedMessage parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ReceivedMessage parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ReceivedMessage parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ReceivedMessage parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static ReceivedMessage parseFrom(InputStream input) throws IOException
IOException
public static ReceivedMessage parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ReceivedMessage parseDelimitedFrom(InputStream input) throws IOException
IOException
public static ReceivedMessage parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static ReceivedMessage parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static ReceivedMessage parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public ReceivedMessage.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static ReceivedMessage.Builder newBuilder()
public static ReceivedMessage.Builder newBuilder(ReceivedMessage prototype)
public ReceivedMessage.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected ReceivedMessage.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static ReceivedMessage getDefaultInstance()
public static com.google.protobuf.Parser<ReceivedMessage> parser()
public com.google.protobuf.Parser<ReceivedMessage> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public ReceivedMessage getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
Copyright © 2023 Google LLC. All rights reserved.