public static final class StreamingPullRequest.Builder extends GeneratedMessageV3.Builder<StreamingPullRequest.Builder> implements StreamingPullRequestOrBuilder
Request for the `StreamingPull` streaming RPC method. This request is used to establish the initial stream as well as to stream acknowledgements and ack deadline modifications from the client to the server.Protobuf type
google.pubsub.v1.StreamingPullRequest| Modifier and Type | Method and Description |
|---|---|
StreamingPullRequest.Builder |
addAckIds(java.lang.String value)
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
StreamingPullRequest.Builder |
addAckIdsBytes(ByteString value)
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
StreamingPullRequest.Builder |
addAllAckIds(java.lang.Iterable<java.lang.String> values)
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
StreamingPullRequest.Builder |
addAllModifyDeadlineAckIds(java.lang.Iterable<java.lang.String> values)
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
StreamingPullRequest.Builder |
addAllModifyDeadlineSeconds(java.lang.Iterable<? extends java.lang.Integer> values)
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
StreamingPullRequest.Builder |
addModifyDeadlineAckIds(java.lang.String value)
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
StreamingPullRequest.Builder |
addModifyDeadlineAckIdsBytes(ByteString value)
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
StreamingPullRequest.Builder |
addModifyDeadlineSeconds(int value)
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
StreamingPullRequest.Builder |
addRepeatedField(Descriptors.FieldDescriptor field,
java.lang.Object value) |
StreamingPullRequest |
build() |
StreamingPullRequest |
buildPartial() |
StreamingPullRequest.Builder |
clear() |
StreamingPullRequest.Builder |
clearAckIds()
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
StreamingPullRequest.Builder |
clearField(Descriptors.FieldDescriptor field) |
StreamingPullRequest.Builder |
clearModifyDeadlineAckIds()
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
StreamingPullRequest.Builder |
clearModifyDeadlineSeconds()
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
StreamingPullRequest.Builder |
clearOneof(Descriptors.OneofDescriptor oneof) |
StreamingPullRequest.Builder |
clearStreamAckDeadlineSeconds()
The ack deadline to use for the stream.
|
StreamingPullRequest.Builder |
clearSubscription()
The subscription for which to initialize the new stream.
|
StreamingPullRequest.Builder |
clone() |
java.lang.String |
getAckIds(int index)
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
ByteString |
getAckIdsBytes(int index)
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
int |
getAckIdsCount()
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
ProtocolStringList |
getAckIdsList()
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
StreamingPullRequest |
getDefaultInstanceForType() |
static Descriptors.Descriptor |
getDescriptor() |
Descriptors.Descriptor |
getDescriptorForType() |
java.lang.String |
getModifyDeadlineAckIds(int index)
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
ByteString |
getModifyDeadlineAckIdsBytes(int index)
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
int |
getModifyDeadlineAckIdsCount()
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
ProtocolStringList |
getModifyDeadlineAckIdsList()
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
int |
getModifyDeadlineSeconds(int index)
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
int |
getModifyDeadlineSecondsCount()
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
java.util.List<java.lang.Integer> |
getModifyDeadlineSecondsList()
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
int |
getStreamAckDeadlineSeconds()
The ack deadline to use for the stream.
|
java.lang.String |
getSubscription()
The subscription for which to initialize the new stream.
|
ByteString |
getSubscriptionBytes()
The subscription for which to initialize the new stream.
|
protected GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
StreamingPullRequest.Builder |
mergeFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
StreamingPullRequest.Builder |
mergeFrom(Message other) |
StreamingPullRequest.Builder |
mergeFrom(StreamingPullRequest other) |
StreamingPullRequest.Builder |
mergeUnknownFields(UnknownFieldSet unknownFields) |
StreamingPullRequest.Builder |
setAckIds(int index,
java.lang.String value)
List of acknowledgement IDs for acknowledging previously received messages
(received on this stream or a different stream).
|
StreamingPullRequest.Builder |
setField(Descriptors.FieldDescriptor field,
java.lang.Object value) |
StreamingPullRequest.Builder |
setModifyDeadlineAckIds(int index,
java.lang.String value)
List of acknowledgement IDs whose deadline will be modified based on the
corresponding element in `modify_deadline_seconds`.
|
StreamingPullRequest.Builder |
setModifyDeadlineSeconds(int index,
int value)
The list of new ack deadlines for the IDs listed in
`modify_deadline_ack_ids`.
|
StreamingPullRequest.Builder |
setRepeatedField(Descriptors.FieldDescriptor field,
int index,
java.lang.Object value) |
StreamingPullRequest.Builder |
setStreamAckDeadlineSeconds(int value)
The ack deadline to use for the stream.
|
StreamingPullRequest.Builder |
setSubscription(java.lang.String value)
The subscription for which to initialize the new stream.
|
StreamingPullRequest.Builder |
setSubscriptionBytes(ByteString value)
The subscription for which to initialize the new stream.
|
StreamingPullRequest.Builder |
setUnknownFields(UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, newBuilderForField, onBuilt, onChanged, setUnknownFieldsProto3findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringaddAll, addAll, mergeFrom, newUninitializedMessageExceptionequals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitfindInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneofmergeFrompublic static final Descriptors.Descriptor getDescriptor()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder clear()
clear in interface Message.Builderclear in interface MessageLite.Builderclear in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public Descriptors.Descriptor getDescriptorForType()
getDescriptorForType in interface Message.BuildergetDescriptorForType in interface MessageOrBuildergetDescriptorForType in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest getDefaultInstanceForType()
getDefaultInstanceForType in interface MessageLiteOrBuildergetDefaultInstanceForType in interface MessageOrBuilderpublic StreamingPullRequest build()
build in interface Message.Builderbuild in interface MessageLite.Builderpublic StreamingPullRequest buildPartial()
buildPartial in interface Message.BuilderbuildPartial in interface MessageLite.Builderpublic StreamingPullRequest.Builder clone()
clone in interface Message.Builderclone in interface MessageLite.Builderclone in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder setField(Descriptors.FieldDescriptor field, java.lang.Object value)
setField in interface Message.BuildersetField in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder clearField(Descriptors.FieldDescriptor field)
clearField in interface Message.BuilderclearField in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder clearOneof(Descriptors.OneofDescriptor oneof)
clearOneof in interface Message.BuilderclearOneof in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, java.lang.Object value)
setRepeatedField in interface Message.BuildersetRepeatedField in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder addRepeatedField(Descriptors.FieldDescriptor field, java.lang.Object value)
addRepeatedField in interface Message.BuilderaddRepeatedField in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder mergeFrom(Message other)
mergeFrom in interface Message.BuildermergeFrom in class AbstractMessage.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder mergeFrom(StreamingPullRequest other)
public final boolean isInitialized()
isInitialized in interface MessageLiteOrBuilderisInitialized in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public StreamingPullRequest.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom in interface Message.BuildermergeFrom in interface MessageLite.BuildermergeFrom in class AbstractMessage.Builder<StreamingPullRequest.Builder>java.io.IOExceptionpublic java.lang.String getSubscription()
The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.
string subscription = 1;getSubscription in interface StreamingPullRequestOrBuilderpublic ByteString getSubscriptionBytes()
The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.
string subscription = 1;getSubscriptionBytes in interface StreamingPullRequestOrBuilderpublic StreamingPullRequest.Builder setSubscription(java.lang.String value)
The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.
string subscription = 1;public StreamingPullRequest.Builder clearSubscription()
The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.
string subscription = 1;public StreamingPullRequest.Builder setSubscriptionBytes(ByteString value)
The subscription for which to initialize the new stream. This must be
provided in the first request on the stream, and must not be set in
subsequent requests from client to server.
Format is `projects/{project}/subscriptions/{sub}`.
string subscription = 1;public ProtocolStringList getAckIdsList()
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;getAckIdsList in interface StreamingPullRequestOrBuilderpublic int getAckIdsCount()
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;getAckIdsCount in interface StreamingPullRequestOrBuilderpublic java.lang.String getAckIds(int index)
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;getAckIds in interface StreamingPullRequestOrBuilderpublic ByteString getAckIdsBytes(int index)
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;getAckIdsBytes in interface StreamingPullRequestOrBuilderpublic StreamingPullRequest.Builder setAckIds(int index, java.lang.String value)
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;public StreamingPullRequest.Builder addAckIds(java.lang.String value)
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;public StreamingPullRequest.Builder addAllAckIds(java.lang.Iterable<java.lang.String> values)
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;public StreamingPullRequest.Builder clearAckIds()
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;public StreamingPullRequest.Builder addAckIdsBytes(ByteString value)
List of acknowledgement IDs for acknowledging previously received messages (received on this stream or a different stream). If an ack ID has expired, the corresponding message may be redelivered later. Acknowledging a message more than once will not result in an error. If the acknowledgement ID is malformed, the stream will be aborted with status `INVALID_ARGUMENT`.
repeated string ack_ids = 2;public java.util.List<java.lang.Integer> getModifyDeadlineSecondsList()
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;getModifyDeadlineSecondsList in interface StreamingPullRequestOrBuilderpublic int getModifyDeadlineSecondsCount()
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;getModifyDeadlineSecondsCount in interface StreamingPullRequestOrBuilderpublic int getModifyDeadlineSeconds(int index)
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;getModifyDeadlineSeconds in interface StreamingPullRequestOrBuilderpublic StreamingPullRequest.Builder setModifyDeadlineSeconds(int index, int value)
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;public StreamingPullRequest.Builder addModifyDeadlineSeconds(int value)
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;public StreamingPullRequest.Builder addAllModifyDeadlineSeconds(java.lang.Iterable<? extends java.lang.Integer> values)
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;public StreamingPullRequest.Builder clearModifyDeadlineSeconds()
The list of new ack deadlines for the IDs listed in `modify_deadline_ack_ids`. The size of this list must be the same as the size of `modify_deadline_ack_ids`. If it differs the stream will be aborted with `INVALID_ARGUMENT`. Each element in this list is applied to the element in the same position in `modify_deadline_ack_ids`. The new ack deadline is with respect to the time this request was sent to the Pub/Sub system. Must be >= 0. For example, if the value is 10, the new ack deadline will expire 10 seconds after this request is received. If the value is 0, the message is immediately made available for another streaming or non-streaming pull request. If the value is < 0 (an error), the stream will be aborted with status `INVALID_ARGUMENT`.
repeated int32 modify_deadline_seconds = 3;public ProtocolStringList getModifyDeadlineAckIdsList()
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;getModifyDeadlineAckIdsList in interface StreamingPullRequestOrBuilderpublic int getModifyDeadlineAckIdsCount()
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;getModifyDeadlineAckIdsCount in interface StreamingPullRequestOrBuilderpublic java.lang.String getModifyDeadlineAckIds(int index)
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;getModifyDeadlineAckIds in interface StreamingPullRequestOrBuilderpublic ByteString getModifyDeadlineAckIdsBytes(int index)
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;getModifyDeadlineAckIdsBytes in interface StreamingPullRequestOrBuilderpublic StreamingPullRequest.Builder setModifyDeadlineAckIds(int index, java.lang.String value)
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;public StreamingPullRequest.Builder addModifyDeadlineAckIds(java.lang.String value)
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;public StreamingPullRequest.Builder addAllModifyDeadlineAckIds(java.lang.Iterable<java.lang.String> values)
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;public StreamingPullRequest.Builder clearModifyDeadlineAckIds()
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;public StreamingPullRequest.Builder addModifyDeadlineAckIdsBytes(ByteString value)
List of acknowledgement IDs whose deadline will be modified based on the corresponding element in `modify_deadline_seconds`. This field can be used to indicate that more time is needed to process a message by the subscriber, or to make the message available for redelivery if the processing was interrupted.
repeated string modify_deadline_ack_ids = 4;public int getStreamAckDeadlineSeconds()
The ack deadline to use for the stream. This must be provided in the first request on the stream, but it can also be updated on subsequent requests from client to server. The minimum deadline you can specify is 10 seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
int32 stream_ack_deadline_seconds = 5;getStreamAckDeadlineSeconds in interface StreamingPullRequestOrBuilderpublic StreamingPullRequest.Builder setStreamAckDeadlineSeconds(int value)
The ack deadline to use for the stream. This must be provided in the first request on the stream, but it can also be updated on subsequent requests from client to server. The minimum deadline you can specify is 10 seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
int32 stream_ack_deadline_seconds = 5;public StreamingPullRequest.Builder clearStreamAckDeadlineSeconds()
The ack deadline to use for the stream. This must be provided in the first request on the stream, but it can also be updated on subsequent requests from client to server. The minimum deadline you can specify is 10 seconds. The maximum deadline you can specify is 600 seconds (10 minutes).
int32 stream_ack_deadline_seconds = 5;public final StreamingPullRequest.Builder setUnknownFields(UnknownFieldSet unknownFields)
setUnknownFields in interface Message.BuildersetUnknownFields in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>public final StreamingPullRequest.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
mergeUnknownFields in interface Message.BuildermergeUnknownFields in class GeneratedMessageV3.Builder<StreamingPullRequest.Builder>