public final class Subscription extends GeneratedMessageV3 implements SubscriptionOrBuilder
A subscription resource.Protobuf type
google.pubsub.v1.Subscription| Modifier and Type | Class and Description |
|---|---|
static class |
Subscription.Builder
A subscription resource.
|
GeneratedMessageV3.BuilderParent, GeneratedMessageV3.ExtendableBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage,BuilderType extends GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, GeneratedMessageV3.ExtendableMessage<MessageType extends GeneratedMessageV3.ExtendableMessage>, GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage>, GeneratedMessageV3.FieldAccessorTable| Modifier and Type | Field and Description |
|---|---|
static int |
ACK_DEADLINE_SECONDS_FIELD_NUMBER |
static int |
LABELS_FIELD_NUMBER |
static int |
MESSAGE_RETENTION_DURATION_FIELD_NUMBER |
static int |
NAME_FIELD_NUMBER |
static int |
PUSH_CONFIG_FIELD_NUMBER |
static int |
RETAIN_ACKED_MESSAGES_FIELD_NUMBER |
static int |
TOPIC_FIELD_NUMBER |
alwaysUseFieldBuilders, unknownFieldsmemoizedSizememoizedHashCode| Modifier and Type | Method and Description |
|---|---|
boolean |
containsLabels(java.lang.String key)
User labels.
|
boolean |
equals(java.lang.Object obj) |
int |
getAckDeadlineSeconds()
This value is the maximum time after a subscriber receives a message
before the subscriber should acknowledge the message.
|
static Subscription |
getDefaultInstance() |
Subscription |
getDefaultInstanceForType() |
static Descriptors.Descriptor |
getDescriptor() |
java.util.Map<java.lang.String,java.lang.String> |
getLabels()
Deprecated.
|
int |
getLabelsCount()
User labels.
|
java.util.Map<java.lang.String,java.lang.String> |
getLabelsMap()
User labels.
|
java.lang.String |
getLabelsOrDefault(java.lang.String key,
java.lang.String defaultValue)
User labels.
|
java.lang.String |
getLabelsOrThrow(java.lang.String key)
User labels.
|
Duration |
getMessageRetentionDuration()
How long to retain unacknowledged messages in the subscription's backlog,
from the moment a message is published.
|
DurationOrBuilder |
getMessageRetentionDurationOrBuilder()
How long to retain unacknowledged messages in the subscription's backlog,
from the moment a message is published.
|
java.lang.String |
getName()
The name of the subscription.
|
ByteString |
getNameBytes()
The name of the subscription.
|
Parser<Subscription> |
getParserForType() |
PushConfig |
getPushConfig()
If push delivery is used with this subscription, this field is
used to configure it.
|
PushConfigOrBuilder |
getPushConfigOrBuilder()
If push delivery is used with this subscription, this field is
used to configure it.
|
boolean |
getRetainAckedMessages()
Indicates whether to retain acknowledged messages.
|
int |
getSerializedSize() |
java.lang.String |
getTopic()
The name of the topic from which this subscription is receiving messages.
|
ByteString |
getTopicBytes()
The name of the topic from which this subscription is receiving messages.
|
UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
boolean |
hasMessageRetentionDuration()
How long to retain unacknowledged messages in the subscription's backlog,
from the moment a message is published.
|
boolean |
hasPushConfig()
If push delivery is used with this subscription, this field is
used to configure it.
|
protected GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
protected MapField |
internalGetMapField(int number) |
boolean |
isInitialized() |
static Subscription.Builder |
newBuilder() |
static Subscription.Builder |
newBuilder(Subscription prototype) |
Subscription.Builder |
newBuilderForType() |
protected Subscription.Builder |
newBuilderForType(GeneratedMessageV3.BuilderParent parent) |
static Subscription |
parseDelimitedFrom(java.io.InputStream input) |
static Subscription |
parseDelimitedFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
parseFrom(byte[] data) |
static Subscription |
parseFrom(byte[] data,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
parseFrom(java.nio.ByteBuffer data) |
static Subscription |
parseFrom(java.nio.ByteBuffer data,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
parseFrom(ByteString data) |
static Subscription |
parseFrom(ByteString data,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
parseFrom(CodedInputStream input) |
static Subscription |
parseFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
static Subscription |
parseFrom(java.io.InputStream input) |
static Subscription |
parseFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static Parser<Subscription> |
parser() |
Subscription.Builder |
toBuilder() |
void |
writeTo(CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, makeExtensionsImmutable, newBuilderForType, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTagfindInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toStringaddAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToclone, finalize, getClass, notify, notifyAll, wait, wait, waitfindInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneoftoByteArray, toByteString, writeDelimitedTo, writeTopublic static final int NAME_FIELD_NUMBER
public static final int TOPIC_FIELD_NUMBER
public static final int PUSH_CONFIG_FIELD_NUMBER
public static final int ACK_DEADLINE_SECONDS_FIELD_NUMBER
public static final int RETAIN_ACKED_MESSAGES_FIELD_NUMBER
public static final int MESSAGE_RETENTION_DURATION_FIELD_NUMBER
public static final int LABELS_FIELD_NUMBER
public final UnknownFieldSet getUnknownFields()
getUnknownFields in interface MessageOrBuildergetUnknownFields in class GeneratedMessageV3public static final Descriptors.Descriptor getDescriptor()
protected MapField internalGetMapField(int number)
internalGetMapField in class GeneratedMessageV3protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class GeneratedMessageV3public java.lang.String getName()
The name of the subscription. It must have the format
`"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must
start with a letter, and contain only letters (`[A-Za-z]`), numbers
(`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`),
plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters
in length, and it must not start with `"goog"`.
string name = 1;getName in interface SubscriptionOrBuilderpublic ByteString getNameBytes()
The name of the subscription. It must have the format
`"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must
start with a letter, and contain only letters (`[A-Za-z]`), numbers
(`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`),
plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters
in length, and it must not start with `"goog"`.
string name = 1;getNameBytes in interface SubscriptionOrBuilderpublic java.lang.String getTopic()
The name of the topic from which this subscription is receiving messages.
Format is `projects/{project}/topics/{topic}`.
The value of this field will be `_deleted-topic_` if the topic has been
deleted.
string topic = 2;getTopic in interface SubscriptionOrBuilderpublic ByteString getTopicBytes()
The name of the topic from which this subscription is receiving messages.
Format is `projects/{project}/topics/{topic}`.
The value of this field will be `_deleted-topic_` if the topic has been
deleted.
string topic = 2;getTopicBytes in interface SubscriptionOrBuilderpublic boolean hasPushConfig()
If push delivery is used with this subscription, this field is used to configure it. An empty `pushConfig` signifies that the subscriber will pull and ack messages using API methods.
.google.pubsub.v1.PushConfig push_config = 4;hasPushConfig in interface SubscriptionOrBuilderpublic PushConfig getPushConfig()
If push delivery is used with this subscription, this field is used to configure it. An empty `pushConfig` signifies that the subscriber will pull and ack messages using API methods.
.google.pubsub.v1.PushConfig push_config = 4;getPushConfig in interface SubscriptionOrBuilderpublic PushConfigOrBuilder getPushConfigOrBuilder()
If push delivery is used with this subscription, this field is used to configure it. An empty `pushConfig` signifies that the subscriber will pull and ack messages using API methods.
.google.pubsub.v1.PushConfig push_config = 4;getPushConfigOrBuilder in interface SubscriptionOrBuilderpublic int getAckDeadlineSeconds()
This value is the maximum time after a subscriber receives a message before the subscriber should acknowledge the message. After message delivery but before the ack deadline expires and before the message is acknowledged, it is an outstanding message and will not be delivered again during that time (on a best-effort basis). For pull subscriptions, this value is used as the initial value for the ack deadline. To override this value for a given message, call `ModifyAckDeadline` with the corresponding `ack_id` if using pull. The minimum custom deadline you can specify is 10 seconds. The maximum custom deadline you can specify is 600 seconds (10 minutes). If this parameter is 0, a default value of 10 seconds is used. For push delivery, this value is also used to set the request timeout for the call to the push endpoint. If the subscriber never acknowledges the message, the Pub/Sub system will eventually redeliver the message.
int32 ack_deadline_seconds = 5;getAckDeadlineSeconds in interface SubscriptionOrBuilderpublic boolean getRetainAckedMessages()
Indicates whether to retain acknowledged messages. If true, then messages are not expunged from the subscription's backlog, even if they are acknowledged, until they fall out of the `message_retention_duration` window.
bool retain_acked_messages = 7;getRetainAckedMessages in interface SubscriptionOrBuilderpublic boolean hasMessageRetentionDuration()
How long to retain unacknowledged messages in the subscription's backlog, from the moment a message is published. If `retain_acked_messages` is true, then this also configures the retention of acknowledged messages, and thus configures how far back in time a `Seek` can be done. Defaults to 7 days. Cannot be more than 7 days or less than 10 minutes.
.google.protobuf.Duration message_retention_duration = 8;hasMessageRetentionDuration in interface SubscriptionOrBuilderpublic Duration getMessageRetentionDuration()
How long to retain unacknowledged messages in the subscription's backlog, from the moment a message is published. If `retain_acked_messages` is true, then this also configures the retention of acknowledged messages, and thus configures how far back in time a `Seek` can be done. Defaults to 7 days. Cannot be more than 7 days or less than 10 minutes.
.google.protobuf.Duration message_retention_duration = 8;getMessageRetentionDuration in interface SubscriptionOrBuilderpublic DurationOrBuilder getMessageRetentionDurationOrBuilder()
How long to retain unacknowledged messages in the subscription's backlog, from the moment a message is published. If `retain_acked_messages` is true, then this also configures the retention of acknowledged messages, and thus configures how far back in time a `Seek` can be done. Defaults to 7 days. Cannot be more than 7 days or less than 10 minutes.
.google.protobuf.Duration message_retention_duration = 8;getMessageRetentionDurationOrBuilder in interface SubscriptionOrBuilderpublic int getLabelsCount()
SubscriptionOrBuilderUser labels.
map<string, string> labels = 9;getLabelsCount in interface SubscriptionOrBuilderpublic boolean containsLabels(java.lang.String key)
User labels.
map<string, string> labels = 9;containsLabels in interface SubscriptionOrBuilder@Deprecated public java.util.Map<java.lang.String,java.lang.String> getLabels()
getLabelsMap() instead.getLabels in interface SubscriptionOrBuilderpublic java.util.Map<java.lang.String,java.lang.String> getLabelsMap()
User labels.
map<string, string> labels = 9;getLabelsMap in interface SubscriptionOrBuilderpublic java.lang.String getLabelsOrDefault(java.lang.String key,
java.lang.String defaultValue)
User labels.
map<string, string> labels = 9;getLabelsOrDefault in interface SubscriptionOrBuilderpublic java.lang.String getLabelsOrThrow(java.lang.String key)
User labels.
map<string, string> labels = 9;getLabelsOrThrow in interface SubscriptionOrBuilderpublic final boolean isInitialized()
isInitialized in interface MessageLiteOrBuilderisInitialized in class GeneratedMessageV3public void writeTo(CodedOutputStream output) throws java.io.IOException
writeTo in interface MessageLitewriteTo in class GeneratedMessageV3java.io.IOExceptionpublic int getSerializedSize()
getSerializedSize in interface MessageLitegetSerializedSize in class GeneratedMessageV3public boolean equals(java.lang.Object obj)
equals in interface Messageequals in class AbstractMessagepublic int hashCode()
hashCode in interface MessagehashCode in class AbstractMessagepublic static Subscription parseFrom(java.nio.ByteBuffer data) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static Subscription parseFrom(java.nio.ByteBuffer data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static Subscription parseFrom(ByteString data) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static Subscription parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static Subscription parseFrom(byte[] data) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static Subscription parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry) throws InvalidProtocolBufferException
InvalidProtocolBufferExceptionpublic static Subscription parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static Subscription parseFrom(java.io.InputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static Subscription parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static Subscription parseDelimitedFrom(java.io.InputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static Subscription parseFrom(CodedInputStream input) throws java.io.IOException
java.io.IOExceptionpublic static Subscription parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic Subscription.Builder newBuilderForType()
newBuilderForType in interface MessagenewBuilderForType in interface MessageLitepublic static Subscription.Builder newBuilder()
public static Subscription.Builder newBuilder(Subscription prototype)
public Subscription.Builder toBuilder()
toBuilder in interface MessagetoBuilder in interface MessageLiteprotected Subscription.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
newBuilderForType in class GeneratedMessageV3public static Subscription getDefaultInstance()
public static Parser<Subscription> parser()
public Parser<Subscription> getParserForType()
getParserForType in interface MessagegetParserForType in interface MessageLitegetParserForType in class GeneratedMessageV3public Subscription getDefaultInstanceForType()
getDefaultInstanceForType in interface MessageLiteOrBuildergetDefaultInstanceForType in interface MessageOrBuilder