public static final class InitialSubscribeRequest.Builder extends GeneratedMessage.Builder<InitialSubscribeRequest.Builder> implements InitialSubscribeRequestOrBuilderThe first request that must be sent on a newly-opened stream. The client must wait for the response before sending subsequent requests on the stream.
Protobuf type google.cloud.pubsublite.v1.InitialSubscribeRequest
Inheritance
java.lang.Object > AbstractMessageLite.Builder<MessageType,BuilderType> > AbstractMessage.Builder<BuilderType> > GeneratedMessage.Builder > InitialSubscribeRequest.BuilderImplements
InitialSubscribeRequestOrBuilderStatic Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()| Returns | |
|---|---|
| Type | Description |
Descriptor |
|
Methods
build()
public InitialSubscribeRequest build()| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest |
|
buildPartial()
public InitialSubscribeRequest buildPartial()| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest |
|
clear()
public InitialSubscribeRequest.Builder clear()| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
clearInitialLocation()
public InitialSubscribeRequest.Builder clearInitialLocation()Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
clearPartition()
public InitialSubscribeRequest.Builder clearPartition() The partition from which to receive messages. Partitions are zero indexed,
so partition must be in the range [0, topic.num_partitions).
int64 partition = 2;
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
This builder for chaining. |
clearSubscription()
public InitialSubscribeRequest.Builder clearSubscription()The subscription from which to receive messages.
string subscription = 1;
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
This builder for chaining. |
getDefaultInstanceForType()
public InitialSubscribeRequest getDefaultInstanceForType()| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest |
|
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()| Returns | |
|---|---|
| Type | Description |
Descriptor |
|
getInitialLocation()
public SeekRequest getInitialLocation()Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
SeekRequest |
The initialLocation. |
getInitialLocationBuilder()
public SeekRequest.Builder getInitialLocationBuilder()Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
SeekRequest.Builder |
|
getInitialLocationOrBuilder()
public SeekRequestOrBuilder getInitialLocationOrBuilder()Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
SeekRequestOrBuilder |
|
getPartition()
public long getPartition() The partition from which to receive messages. Partitions are zero indexed,
so partition must be in the range [0, topic.num_partitions).
int64 partition = 2;
| Returns | |
|---|---|
| Type | Description |
long |
The partition. |
getSubscription()
public String getSubscription()The subscription from which to receive messages.
string subscription = 1;
| Returns | |
|---|---|
| Type | Description |
String |
The subscription. |
getSubscriptionBytes()
public ByteString getSubscriptionBytes()The subscription from which to receive messages.
string subscription = 1;
| Returns | |
|---|---|
| Type | Description |
ByteString |
The bytes for subscription. |
hasInitialLocation()
public boolean hasInitialLocation()Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Returns | |
|---|---|
| Type | Description |
boolean |
Whether the initialLocation field is set. |
internalGetFieldAccessorTable()
protected GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()| Returns | |
|---|---|
| Type | Description |
FieldAccessorTable |
|
isInitialized()
public final boolean isInitialized()| Returns | |
|---|---|
| Type | Description |
boolean |
|
mergeFrom(InitialSubscribeRequest other)
public InitialSubscribeRequest.Builder mergeFrom(InitialSubscribeRequest other)| Parameter | |
|---|---|
| Name | Description |
other |
InitialSubscribeRequest |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public InitialSubscribeRequest.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)| Parameters | |
|---|---|
| Name | Description |
input |
CodedInputStream |
extensionRegistry |
ExtensionRegistryLite |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
| Exceptions | |
|---|---|
| Type | Description |
IOException |
|
mergeFrom(Message other)
public InitialSubscribeRequest.Builder mergeFrom(Message other)| Parameter | |
|---|---|
| Name | Description |
other |
Message |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
mergeInitialLocation(SeekRequest value)
public InitialSubscribeRequest.Builder mergeInitialLocation(SeekRequest value)Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Parameter | |
|---|---|
| Name | Description |
value |
SeekRequest |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
setInitialLocation(SeekRequest value)
public InitialSubscribeRequest.Builder setInitialLocation(SeekRequest value)Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Parameter | |
|---|---|
| Name | Description |
value |
SeekRequest |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
setInitialLocation(SeekRequest.Builder builderForValue)
public InitialSubscribeRequest.Builder setInitialLocation(SeekRequest.Builder builderForValue)Optional. Initial target location within the message backlog. If not set, messages will be delivered from the commit cursor for the given subscription and partition.
.google.cloud.pubsublite.v1.SeekRequest initial_location = 4 [(.google.api.field_behavior) = OPTIONAL];
| Parameter | |
|---|---|
| Name | Description |
builderForValue |
SeekRequest.Builder |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
|
setPartition(long value)
public InitialSubscribeRequest.Builder setPartition(long value) The partition from which to receive messages. Partitions are zero indexed,
so partition must be in the range [0, topic.num_partitions).
int64 partition = 2;
| Parameter | |
|---|---|
| Name | Description |
value |
longThe partition to set. |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
This builder for chaining. |
setSubscription(String value)
public InitialSubscribeRequest.Builder setSubscription(String value)The subscription from which to receive messages.
string subscription = 1;
| Parameter | |
|---|---|
| Name | Description |
value |
StringThe subscription to set. |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
This builder for chaining. |
setSubscriptionBytes(ByteString value)
public InitialSubscribeRequest.Builder setSubscriptionBytes(ByteString value)The subscription from which to receive messages.
string subscription = 1;
| Parameter | |
|---|---|
| Name | Description |
value |
ByteStringThe bytes for subscription to set. |
| Returns | |
|---|---|
| Type | Description |
InitialSubscribeRequest.Builder |
This builder for chaining. |