public final class ReceivedMessage extends GeneratedMessageV3 implements ReceivedMessageOrBuilderA message and its corresponding acknowledgment ID.
Protobuf type google.pubsub.v1.ReceivedMessage
Inheritance
Object > AbstractMessageLite<MessageType,BuilderType> > AbstractMessage > GeneratedMessageV3 > ReceivedMessageImplements
ReceivedMessageOrBuilderStatic Fields
ACK_ID_FIELD_NUMBER
public static final int ACK_ID_FIELD_NUMBER| Type | Description |
| int |
DELIVERY_ATTEMPT_FIELD_NUMBER
public static final int DELIVERY_ATTEMPT_FIELD_NUMBER| Type | Description |
| int |
MESSAGE_FIELD_NUMBER
public static final int MESSAGE_FIELD_NUMBER| Type | Description |
| int |
Static Methods
getDefaultInstance()
public static ReceivedMessage getDefaultInstance()| Type | Description |
| ReceivedMessage |
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()| Type | Description |
| Descriptor |
newBuilder()
public static ReceivedMessage.Builder newBuilder()| Type | Description |
| ReceivedMessage.Builder |
newBuilder(ReceivedMessage prototype)
public static ReceivedMessage.Builder newBuilder(ReceivedMessage prototype)| Name | Description |
| prototype | ReceivedMessage |
| Type | Description |
| ReceivedMessage.Builder |
parseDelimitedFrom(InputStream input)
public static ReceivedMessage parseDelimitedFrom(InputStream input)| Name | Description |
| input | InputStream |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| IOException |
parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
public static ReceivedMessage parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)| Name | Description |
| input | InputStream |
| extensionRegistry | ExtensionRegistryLite |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| IOException |
parseFrom(byte[] data)
public static ReceivedMessage parseFrom(byte[] data)| Name | Description |
| data | byte[] |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| InvalidProtocolBufferException |
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static ReceivedMessage parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)| Name | Description |
| data | byte[] |
| extensionRegistry | ExtensionRegistryLite |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| InvalidProtocolBufferException |
parseFrom(ByteString data)
public static ReceivedMessage parseFrom(ByteString data)| Name | Description |
| data | ByteString |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| InvalidProtocolBufferException |
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static ReceivedMessage parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)| Name | Description |
| data | ByteString |
| extensionRegistry | ExtensionRegistryLite |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| InvalidProtocolBufferException |
parseFrom(CodedInputStream input)
public static ReceivedMessage parseFrom(CodedInputStream input)| Name | Description |
| input | CodedInputStream |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| IOException |
parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public static ReceivedMessage parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)| Name | Description |
| input | CodedInputStream |
| extensionRegistry | ExtensionRegistryLite |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| IOException |
parseFrom(InputStream input)
public static ReceivedMessage parseFrom(InputStream input)| Name | Description |
| input | InputStream |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| IOException |
parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
public static ReceivedMessage parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)| Name | Description |
| input | InputStream |
| extensionRegistry | ExtensionRegistryLite |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| IOException |
parseFrom(ByteBuffer data)
public static ReceivedMessage parseFrom(ByteBuffer data)| Name | Description |
| data | ByteBuffer |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| InvalidProtocolBufferException |
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static ReceivedMessage parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)| Name | Description |
| data | ByteBuffer |
| extensionRegistry | ExtensionRegistryLite |
| Type | Description |
| ReceivedMessage |
| Type | Description |
| InvalidProtocolBufferException |
parser()
public static Parser<ReceivedMessage> parser()| Type | Description |
| Parser<ReceivedMessage> |
Methods
equals(Object obj)
public boolean equals(Object obj)| Name | Description |
| obj | Object |
| Type | Description |
| boolean |
getAckId()
public String getAckId()This ID can be used to acknowledge the received message.
string ack_id = 1;
| Type | Description |
| String | The ackId. |
getAckIdBytes()
public ByteString getAckIdBytes()This ID can be used to acknowledge the received message.
string ack_id = 1;
| Type | Description |
| ByteString | The bytes for ackId. |
getDefaultInstanceForType()
public ReceivedMessage getDefaultInstanceForType()| Type | Description |
| ReceivedMessage |
getDeliveryAttempt()
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;
| Type | Description |
| int | The deliveryAttempt. |
getMessage()
public PubsubMessage getMessage()The message.
.google.pubsub.v1.PubsubMessage message = 2;
| Type | Description |
| PubsubMessage | The message. |
getMessageOrBuilder()
public PubsubMessageOrBuilder getMessageOrBuilder()The message.
.google.pubsub.v1.PubsubMessage message = 2;
| Type | Description |
| PubsubMessageOrBuilder |
getParserForType()
public Parser<ReceivedMessage> getParserForType()| Type | Description |
| Parser<ReceivedMessage> |
getSerializedSize()
public int getSerializedSize()| Type | Description |
| int |
getUnknownFields()
public final UnknownFieldSet getUnknownFields()| Type | Description |
| UnknownFieldSet |
hasMessage()
public boolean hasMessage()The message.
.google.pubsub.v1.PubsubMessage message = 2;
| Type | Description |
| boolean | Whether the message field is set. |
hashCode()
public int hashCode()| Type | Description |
| int |
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()| Type | Description |
| FieldAccessorTable |
isInitialized()
public final boolean isInitialized()| Type | Description |
| boolean |
newBuilderForType()
public ReceivedMessage.Builder newBuilderForType()| Type | Description |
| ReceivedMessage.Builder |
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected ReceivedMessage.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)| Name | Description |
| parent | BuilderParent |
| Type | Description |
| ReceivedMessage.Builder |
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)| Name | Description |
| unused | UnusedPrivateParameter |
| Type | Description |
| Object |
toBuilder()
public ReceivedMessage.Builder toBuilder()| Type | Description |
| ReceivedMessage.Builder |
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)| Name | Description |
| output | CodedOutputStream |
| Type | Description |
| IOException |