diff --git a/java/grpc-google-cloud-pubsub-v1/0.1.19/apidocs/allclasses-frame.html b/java/grpc-google-cloud-pubsub-v1/0.1.19/apidocs/allclasses-frame.html new file mode 100644 index 0000000000..3848eca4ff --- /dev/null +++ b/java/grpc-google-cloud-pubsub-v1/0.1.19/apidocs/allclasses-frame.html @@ -0,0 +1,28 @@ + + + +
+ +public static final class PublisherGrpc.PublisherBlockingStub +extends io.grpc.stub.AbstractStub<PublisherGrpc.PublisherBlockingStub>+
+ The service that an application uses to manipulate topics, and to send + messages to a topic. +
| Modifier and Type | +Method and Description | +
|---|---|
protected PublisherGrpc.PublisherBlockingStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.pubsub.v1.Topic |
+createTopic(com.google.pubsub.v1.Topic request)
+
+ Creates the given topic with the given name.
+ |
+
com.google.protobuf.Empty |
+deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request)
+
+ Deletes the topic with the given name.
+ |
+
com.google.pubsub.v1.Topic |
+getTopic(com.google.pubsub.v1.GetTopicRequest request)
+
+ Gets the configuration of a topic.
+ |
+
com.google.pubsub.v1.ListTopicsResponse |
+listTopics(com.google.pubsub.v1.ListTopicsRequest request)
+
+ Lists matching topics.
+ |
+
com.google.pubsub.v1.ListTopicSubscriptionsResponse |
+listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request)
+
+ Lists the name of the subscriptions for this topic.
+ |
+
com.google.pubsub.v1.PublishResponse |
+publish(com.google.pubsub.v1.PublishRequest request)
+
+ Adds one or more messages to the topic.
+ |
+
com.google.pubsub.v1.Topic |
+updateTopic(com.google.pubsub.v1.UpdateTopicRequest request)
+
+ Updates an existing topic.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected PublisherGrpc.PublisherBlockingStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<PublisherGrpc.PublisherBlockingStub>public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request)+
+ Creates the given topic with the given name. +
public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRequest request)+
+ Updates an existing topic. Note that certain properties of a topic are not + modifiable. Options settings follow the style guide: + NOTE: The style guide requires body: "topic" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public com.google.pubsub.v1.PublishResponse publish(com.google.pubsub.v1.PublishRequest request)+
+ Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic + does not exist. The message payload must not be empty; it must contain + either a non-empty data field, or at least one attribute. +
public com.google.pubsub.v1.Topic getTopic(com.google.pubsub.v1.GetTopicRequest request)+
+ Gets the configuration of a topic. +
public com.google.pubsub.v1.ListTopicsResponse listTopics(com.google.pubsub.v1.ListTopicsRequest request)+
+ Lists matching topics. +
public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request)+
+ Lists the name of the subscriptions for this topic. +
public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request)+
+ Deletes the topic with the given name. Returns `NOT_FOUND` if the topic + does not exist. After a topic is deleted, a new topic may be created with + the same name; this is an entirely new topic with none of the old + configuration or subscriptions. Existing subscriptions to this topic are + not deleted, but their `topic` field is set to `_deleted-topic_`. +
public static final class PublisherGrpc.PublisherFutureStub +extends io.grpc.stub.AbstractStub<PublisherGrpc.PublisherFutureStub>+
+ The service that an application uses to manipulate topics, and to send + messages to a topic. +
| Modifier and Type | +Method and Description | +
|---|---|
protected PublisherGrpc.PublisherFutureStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> |
+createTopic(com.google.pubsub.v1.Topic request)
+
+ Creates the given topic with the given name.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request)
+
+ Deletes the topic with the given name.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> |
+getTopic(com.google.pubsub.v1.GetTopicRequest request)
+
+ Gets the configuration of a topic.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListTopicsResponse> |
+listTopics(com.google.pubsub.v1.ListTopicsRequest request)
+
+ Lists matching topics.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListTopicSubscriptionsResponse> |
+listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request)
+
+ Lists the name of the subscriptions for this topic.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.PublishResponse> |
+publish(com.google.pubsub.v1.PublishRequest request)
+
+ Adds one or more messages to the topic.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> |
+updateTopic(com.google.pubsub.v1.UpdateTopicRequest request)
+
+ Updates an existing topic.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected PublisherGrpc.PublisherFutureStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<PublisherGrpc.PublisherFutureStub>public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> createTopic(com.google.pubsub.v1.Topic request)+
+ Creates the given topic with the given name. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> updateTopic(com.google.pubsub.v1.UpdateTopicRequest request)+
+ Updates an existing topic. Note that certain properties of a topic are not + modifiable. Options settings follow the style guide: + NOTE: The style guide requires body: "topic" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.PublishResponse> publish(com.google.pubsub.v1.PublishRequest request)+
+ Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic + does not exist. The message payload must not be empty; it must contain + either a non-empty data field, or at least one attribute. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Topic> getTopic(com.google.pubsub.v1.GetTopicRequest request)+
+ Gets the configuration of a topic. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListTopicsResponse> listTopics(com.google.pubsub.v1.ListTopicsRequest request)+
+ Lists matching topics. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListTopicSubscriptionsResponse> listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request)+
+ Lists the name of the subscriptions for this topic. +
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request)+
+ Deletes the topic with the given name. Returns `NOT_FOUND` if the topic + does not exist. After a topic is deleted, a new topic may be created with + the same name; this is an entirely new topic with none of the old + configuration or subscriptions. Existing subscriptions to this topic are + not deleted, but their `topic` field is set to `_deleted-topic_`. +
public abstract static class PublisherGrpc.PublisherImplBase
+extends java.lang.Object
+implements io.grpc.BindableService
++ The service that an application uses to manipulate topics, and to send + messages to a topic. +
| Constructor and Description | +
|---|
PublisherImplBase() |
+
| Modifier and Type | +Method and Description | +
|---|---|
io.grpc.ServerServiceDefinition |
+bindService() |
+
void |
+createTopic(com.google.pubsub.v1.Topic request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)
+
+ Creates the given topic with the given name.
+ |
+
void |
+deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Deletes the topic with the given name.
+ |
+
void |
+getTopic(com.google.pubsub.v1.GetTopicRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)
+
+ Gets the configuration of a topic.
+ |
+
void |
+listTopics(com.google.pubsub.v1.ListTopicsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicsResponse> responseObserver)
+
+ Lists matching topics.
+ |
+
void |
+listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSubscriptionsResponse> responseObserver)
+
+ Lists the name of the subscriptions for this topic.
+ |
+
void |
+publish(com.google.pubsub.v1.PublishRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.PublishResponse> responseObserver)
+
+ Adds one or more messages to the topic.
+ |
+
void |
+updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)
+
+ Updates an existing topic.
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic void createTopic(com.google.pubsub.v1.Topic request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)+
+ Creates the given topic with the given name. +
public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)+
+ Updates an existing topic. Note that certain properties of a topic are not + modifiable. Options settings follow the style guide: + NOTE: The style guide requires body: "topic" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public void publish(com.google.pubsub.v1.PublishRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.PublishResponse> responseObserver)+
+ Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic + does not exist. The message payload must not be empty; it must contain + either a non-empty data field, or at least one attribute. +
public void getTopic(com.google.pubsub.v1.GetTopicRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)+
+ Gets the configuration of a topic. +
public void listTopics(com.google.pubsub.v1.ListTopicsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicsResponse> responseObserver)+
+ Lists matching topics. +
public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSubscriptionsResponse> responseObserver)+
+ Lists the name of the subscriptions for this topic. +
public void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Deletes the topic with the given name. Returns `NOT_FOUND` if the topic + does not exist. After a topic is deleted, a new topic may be created with + the same name; this is an entirely new topic with none of the old + configuration or subscriptions. Existing subscriptions to this topic are + not deleted, but their `topic` field is set to `_deleted-topic_`. +
public final io.grpc.ServerServiceDefinition bindService()+
bindService in interface io.grpc.BindableServicepublic static final class PublisherGrpc.PublisherStub +extends io.grpc.stub.AbstractStub<PublisherGrpc.PublisherStub>+
+ The service that an application uses to manipulate topics, and to send + messages to a topic. +
| Modifier and Type | +Method and Description | +
|---|---|
protected PublisherGrpc.PublisherStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
void |
+createTopic(com.google.pubsub.v1.Topic request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)
+
+ Creates the given topic with the given name.
+ |
+
void |
+deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Deletes the topic with the given name.
+ |
+
void |
+getTopic(com.google.pubsub.v1.GetTopicRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)
+
+ Gets the configuration of a topic.
+ |
+
void |
+listTopics(com.google.pubsub.v1.ListTopicsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicsResponse> responseObserver)
+
+ Lists matching topics.
+ |
+
void |
+listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSubscriptionsResponse> responseObserver)
+
+ Lists the name of the subscriptions for this topic.
+ |
+
void |
+publish(com.google.pubsub.v1.PublishRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.PublishResponse> responseObserver)
+
+ Adds one or more messages to the topic.
+ |
+
void |
+updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)
+
+ Updates an existing topic.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected PublisherGrpc.PublisherStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<PublisherGrpc.PublisherStub>public void createTopic(com.google.pubsub.v1.Topic request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)+
+ Creates the given topic with the given name. +
public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)+
+ Updates an existing topic. Note that certain properties of a topic are not + modifiable. Options settings follow the style guide: + NOTE: The style guide requires body: "topic" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public void publish(com.google.pubsub.v1.PublishRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.PublishResponse> responseObserver)+
+ Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic + does not exist. The message payload must not be empty; it must contain + either a non-empty data field, or at least one attribute. +
public void getTopic(com.google.pubsub.v1.GetTopicRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Topic> responseObserver)+
+ Gets the configuration of a topic. +
public void listTopics(com.google.pubsub.v1.ListTopicsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicsResponse> responseObserver)+
+ Lists matching topics. +
public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListTopicSubscriptionsResponse> responseObserver)+
+ Lists the name of the subscriptions for this topic. +
public void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Deletes the topic with the given name. Returns `NOT_FOUND` if the topic + does not exist. After a topic is deleted, a new topic may be created with + the same name; this is an entirely new topic with none of the old + configuration or subscriptions. Existing subscriptions to this topic are + not deleted, but their `topic` field is set to `_deleted-topic_`. +
@Generated(value="by gRPC proto compiler (version 1.2.0)",
+ comments="Source: google/pubsub/v1/pubsub.proto")
+public final class PublisherGrpc
+extends java.lang.Object
++ The service that an application uses to manipulate topics, and to send + messages to a topic. +
| Modifier and Type | +Class and Description | +
|---|---|
static class |
+PublisherGrpc.PublisherBlockingStub
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
static class |
+PublisherGrpc.PublisherFutureStub
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
static class |
+PublisherGrpc.PublisherImplBase
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
static class |
+PublisherGrpc.PublisherStub
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
| Modifier and Type | +Field and Description | +
|---|---|
static io.grpc.MethodDescriptor<com.google.pubsub.v1.Topic,com.google.pubsub.v1.Topic> |
+METHOD_CREATE_TOPIC |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteTopicRequest,com.google.protobuf.Empty> |
+METHOD_DELETE_TOPIC |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.GetTopicRequest,com.google.pubsub.v1.Topic> |
+METHOD_GET_TOPIC |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSubscriptionsRequest,com.google.pubsub.v1.ListTopicSubscriptionsResponse> |
+METHOD_LIST_TOPIC_SUBSCRIPTIONS |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicsRequest,com.google.pubsub.v1.ListTopicsResponse> |
+METHOD_LIST_TOPICS |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.PublishRequest,com.google.pubsub.v1.PublishResponse> |
+METHOD_PUBLISH |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.UpdateTopicRequest,com.google.pubsub.v1.Topic> |
+METHOD_UPDATE_TOPIC |
+
static java.lang.String |
+SERVICE_NAME |
+
| Modifier and Type | +Method and Description | +
|---|---|
static io.grpc.ServiceDescriptor |
+getServiceDescriptor() |
+
static PublisherGrpc.PublisherBlockingStub |
+newBlockingStub(io.grpc.Channel channel)
+Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ |
+
static PublisherGrpc.PublisherFutureStub |
+newFutureStub(io.grpc.Channel channel)
+Creates a new ListenableFuture-style stub that supports unary and streaming output calls on the service
+ |
+
static PublisherGrpc.PublisherStub |
+newStub(io.grpc.Channel channel)
+Creates a new async stub that supports all call types for the service
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final java.lang.String SERVICE_NAME+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.Topic,com.google.pubsub.v1.Topic> METHOD_CREATE_TOPIC+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.UpdateTopicRequest,com.google.pubsub.v1.Topic> METHOD_UPDATE_TOPIC+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.PublishRequest,com.google.pubsub.v1.PublishResponse> METHOD_PUBLISH+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.GetTopicRequest,com.google.pubsub.v1.Topic> METHOD_GET_TOPIC+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicsRequest,com.google.pubsub.v1.ListTopicsResponse> METHOD_LIST_TOPICS+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ListTopicSubscriptionsRequest,com.google.pubsub.v1.ListTopicSubscriptionsResponse> METHOD_LIST_TOPIC_SUBSCRIPTIONS+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteTopicRequest,com.google.protobuf.Empty> METHOD_DELETE_TOPIC+
public static PublisherGrpc.PublisherStub newStub(io.grpc.Channel channel)+
public static PublisherGrpc.PublisherBlockingStub newBlockingStub(io.grpc.Channel channel)+
public static PublisherGrpc.PublisherFutureStub newFutureStub(io.grpc.Channel channel)+
public static io.grpc.ServiceDescriptor getServiceDescriptor()+
public static final class SubscriberGrpc.SubscriberBlockingStub +extends io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberBlockingStub>+
+ The service that an application uses to manipulate subscriptions and to + consume messages from a subscription via the `Pull` method. +
| Modifier and Type | +Method and Description | +
|---|---|
com.google.protobuf.Empty |
+acknowledge(com.google.pubsub.v1.AcknowledgeRequest request)
+
+ Acknowledges the messages associated with the `ack_ids` in the
+ `AcknowledgeRequest`.
+ |
+
protected SubscriberGrpc.SubscriberBlockingStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.pubsub.v1.Snapshot |
+createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request)
+
+ Creates a snapshot from the requested subscription.
+ |
+
com.google.pubsub.v1.Subscription |
+createSubscription(com.google.pubsub.v1.Subscription request)
+
+ Creates a subscription to a given topic.
+ |
+
com.google.protobuf.Empty |
+deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request)
+
+ Removes an existing snapshot.
+ |
+
com.google.protobuf.Empty |
+deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request)
+
+ Deletes an existing subscription.
+ |
+
com.google.pubsub.v1.Subscription |
+getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request)
+
+ Gets the configuration details of a subscription.
+ |
+
com.google.pubsub.v1.ListSnapshotsResponse |
+listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request)
+
+ Lists the existing snapshots.
+ |
+
com.google.pubsub.v1.ListSubscriptionsResponse |
+listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request)
+
+ Lists matching subscriptions.
+ |
+
com.google.protobuf.Empty |
+modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request)
+
+ Modifies the ack deadline for a specific message.
+ |
+
com.google.protobuf.Empty |
+modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request)
+
+ Modifies the `PushConfig` for a specified subscription.
+ |
+
com.google.pubsub.v1.PullResponse |
+pull(com.google.pubsub.v1.PullRequest request)
+
+ Pulls messages from the server.
+ |
+
com.google.pubsub.v1.SeekResponse |
+seek(com.google.pubsub.v1.SeekRequest request)
+
+ Seeks an existing subscription to a point in time or to a given snapshot,
+ whichever is provided in the request.
+ |
+
com.google.pubsub.v1.Snapshot |
+updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request)
+
+ Updates an existing snapshot.
+ |
+
com.google.pubsub.v1.Subscription |
+updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request)
+
+ Updates an existing subscription.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected SubscriberGrpc.SubscriberBlockingStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberBlockingStub>public com.google.pubsub.v1.Subscription createSubscription(com.google.pubsub.v1.Subscription request)+
+ Creates a subscription to a given topic. + If the subscription already exists, returns `ALREADY_EXISTS`. + If the corresponding topic doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this subscription on the same project as the topic, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Subscription object. + Note that for REST API requests, you must specify a name in the request. +
public com.google.pubsub.v1.Subscription getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request)+
+ Gets the configuration details of a subscription. +
public com.google.pubsub.v1.Subscription updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request)+
+ Updates an existing subscription. Note that certain properties of a + subscription, such as its topic, are not modifiable. + NOTE: The style guide requires body: "subscription" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public com.google.pubsub.v1.ListSubscriptionsResponse listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request)+
+ Lists matching subscriptions. +
public com.google.protobuf.Empty deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request)+
+ Deletes an existing subscription. All messages retained in the subscription + are immediately dropped. Calls to `Pull` after deletion will return + `NOT_FOUND`. After a subscription is deleted, a new one may be created with + the same name, but the new one has no association with the old + subscription or its topic unless the same topic is specified. +
public com.google.protobuf.Empty modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request)+
+ Modifies the ack deadline for a specific message. This method is useful + 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. Note that this does not modify the + subscription-level `ackDeadlineSeconds` used for subsequent messages. +
public com.google.protobuf.Empty acknowledge(com.google.pubsub.v1.AcknowledgeRequest request)+
+ Acknowledges the messages associated with the `ack_ids` in the + `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages + from the subscription. + Acknowledging a message whose ack deadline has expired may succeed, + but such a message may be redelivered later. Acknowledging a message more + than once will not result in an error. +
public com.google.pubsub.v1.PullResponse pull(com.google.pubsub.v1.PullRequest request)+
+ Pulls messages from the server. Returns an empty list if there are no + messages available in the backlog. The server may return `UNAVAILABLE` if + there are too many concurrent pull requests pending for the given + subscription. +
public com.google.protobuf.Empty modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request)+
+ Modifies the `PushConfig` for a specified subscription. + This may be used to change a push subscription to a pull one (signified by + an empty `PushConfig`) or vice versa, or change the endpoint URL and other + attributes of a push subscription. Messages will accumulate for delivery + continuously through the call regardless of changes to the `PushConfig`. +
public com.google.pubsub.v1.ListSnapshotsResponse listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request)+
+ Lists the existing snapshots. +
public com.google.pubsub.v1.Snapshot createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request)+
+ Creates a snapshot from the requested subscription. + If the snapshot already exists, returns `ALREADY_EXISTS`. + If the requested subscription doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this snapshot on the same project as the subscription, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Snapshot object. + Note that for REST API requests, you must specify a name in the request. +
public com.google.pubsub.v1.Snapshot updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request)+
+ Updates an existing snapshot. Note that certain properties of a snapshot + are not modifiable. + NOTE: The style guide requires body: "snapshot" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public com.google.protobuf.Empty deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request)+
+ Removes an existing snapshot. All messages retained in the snapshot + are immediately dropped. After a snapshot is deleted, a new one may be + created with the same name, but the new one has no association with the old + snapshot or its subscription, unless the same subscription is specified. +
public com.google.pubsub.v1.SeekResponse seek(com.google.pubsub.v1.SeekRequest request)+
+ Seeks an existing subscription to a point in time or to a given snapshot, + whichever is provided in the request. +
public static final class SubscriberGrpc.SubscriberFutureStub +extends io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberFutureStub>+
+ The service that an application uses to manipulate subscriptions and to + consume messages from a subscription via the `Pull` method. +
| Modifier and Type | +Method and Description | +
|---|---|
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+acknowledge(com.google.pubsub.v1.AcknowledgeRequest request)
+
+ Acknowledges the messages associated with the `ack_ids` in the
+ `AcknowledgeRequest`.
+ |
+
protected SubscriberGrpc.SubscriberFutureStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Snapshot> |
+createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request)
+
+ Creates a snapshot from the requested subscription.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Subscription> |
+createSubscription(com.google.pubsub.v1.Subscription request)
+
+ Creates a subscription to a given topic.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request)
+
+ Removes an existing snapshot.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request)
+
+ Deletes an existing subscription.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Subscription> |
+getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request)
+
+ Gets the configuration details of a subscription.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListSnapshotsResponse> |
+listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request)
+
+ Lists the existing snapshots.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListSubscriptionsResponse> |
+listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request)
+
+ Lists matching subscriptions.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request)
+
+ Modifies the ack deadline for a specific message.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> |
+modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request)
+
+ Modifies the `PushConfig` for a specified subscription.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.PullResponse> |
+pull(com.google.pubsub.v1.PullRequest request)
+
+ Pulls messages from the server.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.SeekResponse> |
+seek(com.google.pubsub.v1.SeekRequest request)
+
+ Seeks an existing subscription to a point in time or to a given snapshot,
+ whichever is provided in the request.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Snapshot> |
+updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request)
+
+ Updates an existing snapshot.
+ |
+
com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Subscription> |
+updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request)
+
+ Updates an existing subscription.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected SubscriberGrpc.SubscriberFutureStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberFutureStub>public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Subscription> createSubscription(com.google.pubsub.v1.Subscription request)+
+ Creates a subscription to a given topic. + If the subscription already exists, returns `ALREADY_EXISTS`. + If the corresponding topic doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this subscription on the same project as the topic, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Subscription object. + Note that for REST API requests, you must specify a name in the request. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Subscription> getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request)+
+ Gets the configuration details of a subscription. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Subscription> updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request)+
+ Updates an existing subscription. Note that certain properties of a + subscription, such as its topic, are not modifiable. + NOTE: The style guide requires body: "subscription" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListSubscriptionsResponse> listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request)+
+ Lists matching subscriptions. +
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request)+
+ Deletes an existing subscription. All messages retained in the subscription + are immediately dropped. Calls to `Pull` after deletion will return + `NOT_FOUND`. After a subscription is deleted, a new one may be created with + the same name, but the new one has no association with the old + subscription or its topic unless the same topic is specified. +
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request)+
+ Modifies the ack deadline for a specific message. This method is useful + 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. Note that this does not modify the + subscription-level `ackDeadlineSeconds` used for subsequent messages. +
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> acknowledge(com.google.pubsub.v1.AcknowledgeRequest request)+
+ Acknowledges the messages associated with the `ack_ids` in the + `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages + from the subscription. + Acknowledging a message whose ack deadline has expired may succeed, + but such a message may be redelivered later. Acknowledging a message more + than once will not result in an error. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.PullResponse> pull(com.google.pubsub.v1.PullRequest request)+
+ Pulls messages from the server. Returns an empty list if there are no + messages available in the backlog. The server may return `UNAVAILABLE` if + there are too many concurrent pull requests pending for the given + subscription. +
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request)+
+ Modifies the `PushConfig` for a specified subscription. + This may be used to change a push subscription to a pull one (signified by + an empty `PushConfig`) or vice versa, or change the endpoint URL and other + attributes of a push subscription. Messages will accumulate for delivery + continuously through the call regardless of changes to the `PushConfig`. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.ListSnapshotsResponse> listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request)+
+ Lists the existing snapshots. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Snapshot> createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request)+
+ Creates a snapshot from the requested subscription. + If the snapshot already exists, returns `ALREADY_EXISTS`. + If the requested subscription doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this snapshot on the same project as the subscription, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Snapshot object. + Note that for REST API requests, you must specify a name in the request. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Snapshot> updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request)+
+ Updates an existing snapshot. Note that certain properties of a snapshot + are not modifiable. + NOTE: The style guide requires body: "snapshot" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request)+
+ Removes an existing snapshot. All messages retained in the snapshot + are immediately dropped. After a snapshot is deleted, a new one may be + created with the same name, but the new one has no association with the old + snapshot or its subscription, unless the same subscription is specified. +
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.SeekResponse> seek(com.google.pubsub.v1.SeekRequest request)+
+ Seeks an existing subscription to a point in time or to a given snapshot, + whichever is provided in the request. +
public abstract static class SubscriberGrpc.SubscriberImplBase
+extends java.lang.Object
+implements io.grpc.BindableService
++ The service that an application uses to manipulate subscriptions and to + consume messages from a subscription via the `Pull` method. +
| Constructor and Description | +
|---|
SubscriberImplBase() |
+
| Modifier and Type | +Method and Description | +
|---|---|
void |
+acknowledge(com.google.pubsub.v1.AcknowledgeRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Acknowledges the messages associated with the `ack_ids` in the
+ `AcknowledgeRequest`.
+ |
+
io.grpc.ServerServiceDefinition |
+bindService() |
+
void |
+createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)
+
+ Creates a snapshot from the requested subscription.
+ |
+
void |
+createSubscription(com.google.pubsub.v1.Subscription request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)
+
+ Creates a subscription to a given topic.
+ |
+
void |
+deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Removes an existing snapshot.
+ |
+
void |
+deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Deletes an existing subscription.
+ |
+
void |
+getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)
+
+ Gets the configuration details of a subscription.
+ |
+
void |
+listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSnapshotsResponse> responseObserver)
+
+ Lists the existing snapshots.
+ |
+
void |
+listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSubscriptionsResponse> responseObserver)
+
+ Lists matching subscriptions.
+ |
+
void |
+modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Modifies the ack deadline for a specific message.
+ |
+
void |
+modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Modifies the `PushConfig` for a specified subscription.
+ |
+
void |
+pull(com.google.pubsub.v1.PullRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.PullResponse> responseObserver)
+
+ Pulls messages from the server.
+ |
+
void |
+seek(com.google.pubsub.v1.SeekRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.SeekResponse> responseObserver)
+
+ Seeks an existing subscription to a point in time or to a given snapshot,
+ whichever is provided in the request.
+ |
+
io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullRequest> |
+streamingPull(io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullResponse> responseObserver)
+
+ (EXPERIMENTAL) StreamingPull is an experimental feature.
+ |
+
void |
+updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)
+
+ Updates an existing snapshot.
+ |
+
void |
+updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)
+
+ Updates an existing subscription.
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic void createSubscription(com.google.pubsub.v1.Subscription request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)+
+ Creates a subscription to a given topic. + If the subscription already exists, returns `ALREADY_EXISTS`. + If the corresponding topic doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this subscription on the same project as the topic, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Subscription object. + Note that for REST API requests, you must specify a name in the request. +
public void getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)+
+ Gets the configuration details of a subscription. +
public void updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)+
+ Updates an existing subscription. Note that certain properties of a + subscription, such as its topic, are not modifiable. + NOTE: The style guide requires body: "subscription" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public void listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSubscriptionsResponse> responseObserver)+
+ Lists matching subscriptions. +
public void deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Deletes an existing subscription. All messages retained in the subscription + are immediately dropped. Calls to `Pull` after deletion will return + `NOT_FOUND`. After a subscription is deleted, a new one may be created with + the same name, but the new one has no association with the old + subscription or its topic unless the same topic is specified. +
public void modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Modifies the ack deadline for a specific message. This method is useful + 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. Note that this does not modify the + subscription-level `ackDeadlineSeconds` used for subsequent messages. +
public void acknowledge(com.google.pubsub.v1.AcknowledgeRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Acknowledges the messages associated with the `ack_ids` in the + `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages + from the subscription. + Acknowledging a message whose ack deadline has expired may succeed, + but such a message may be redelivered later. Acknowledging a message more + than once will not result in an error. +
public void pull(com.google.pubsub.v1.PullRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.PullResponse> responseObserver)+
+ Pulls messages from the server. Returns an empty list if there are no + messages available in the backlog. The server may return `UNAVAILABLE` if + there are too many concurrent pull requests pending for the given + subscription. +
public io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullRequest> streamingPull(io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullResponse> responseObserver)+
+ (EXPERIMENTAL) StreamingPull is an experimental feature. This RPC will + respond with UNIMPLEMENTED errors unless you have been invited to test + this feature. Contact cloud-pubsub@google.com with any questions. + Establishes a stream with the server, which sends messages down to the + client. The client streams acknowledgements and ack deadline modifications + back to the server. The server will close the stream and return the status + on any error. The server may close the stream with status `OK` to reassign + server-side resources, in which case, the client should re-establish the + stream. `UNAVAILABLE` may also be returned in the case of a transient error + (e.g., a server restart). These should also be retried by the client. Flow + control can be achieved by configuring the underlying RPC channel. +
public void modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Modifies the `PushConfig` for a specified subscription. + This may be used to change a push subscription to a pull one (signified by + an empty `PushConfig`) or vice versa, or change the endpoint URL and other + attributes of a push subscription. Messages will accumulate for delivery + continuously through the call regardless of changes to the `PushConfig`. +
public void listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSnapshotsResponse> responseObserver)+
+ Lists the existing snapshots. +
public void createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)+
+ Creates a snapshot from the requested subscription. + If the snapshot already exists, returns `ALREADY_EXISTS`. + If the requested subscription doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this snapshot on the same project as the subscription, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Snapshot object. + Note that for REST API requests, you must specify a name in the request. +
public void updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)+
+ Updates an existing snapshot. Note that certain properties of a snapshot + are not modifiable. + NOTE: The style guide requires body: "snapshot" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public void deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Removes an existing snapshot. All messages retained in the snapshot + are immediately dropped. After a snapshot is deleted, a new one may be + created with the same name, but the new one has no association with the old + snapshot or its subscription, unless the same subscription is specified. +
public void seek(com.google.pubsub.v1.SeekRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.SeekResponse> responseObserver)+
+ Seeks an existing subscription to a point in time or to a given snapshot, + whichever is provided in the request. +
public final io.grpc.ServerServiceDefinition bindService()+
bindService in interface io.grpc.BindableServicepublic static final class SubscriberGrpc.SubscriberStub +extends io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberStub>+
+ The service that an application uses to manipulate subscriptions and to + consume messages from a subscription via the `Pull` method. +
| Modifier and Type | +Method and Description | +
|---|---|
void |
+acknowledge(com.google.pubsub.v1.AcknowledgeRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Acknowledges the messages associated with the `ack_ids` in the
+ `AcknowledgeRequest`.
+ |
+
protected SubscriberGrpc.SubscriberStub |
+build(io.grpc.Channel channel,
+ io.grpc.CallOptions callOptions) |
+
void |
+createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)
+
+ Creates a snapshot from the requested subscription.
+ |
+
void |
+createSubscription(com.google.pubsub.v1.Subscription request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)
+
+ Creates a subscription to a given topic.
+ |
+
void |
+deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Removes an existing snapshot.
+ |
+
void |
+deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Deletes an existing subscription.
+ |
+
void |
+getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)
+
+ Gets the configuration details of a subscription.
+ |
+
void |
+listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSnapshotsResponse> responseObserver)
+
+ Lists the existing snapshots.
+ |
+
void |
+listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSubscriptionsResponse> responseObserver)
+
+ Lists matching subscriptions.
+ |
+
void |
+modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Modifies the ack deadline for a specific message.
+ |
+
void |
+modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request,
+ io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
+
+ Modifies the `PushConfig` for a specified subscription.
+ |
+
void |
+pull(com.google.pubsub.v1.PullRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.PullResponse> responseObserver)
+
+ Pulls messages from the server.
+ |
+
void |
+seek(com.google.pubsub.v1.SeekRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.SeekResponse> responseObserver)
+
+ Seeks an existing subscription to a point in time or to a given snapshot,
+ whichever is provided in the request.
+ |
+
io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullRequest> |
+streamingPull(io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullResponse> responseObserver)
+
+ (EXPERIMENTAL) StreamingPull is an experimental feature.
+ |
+
void |
+updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)
+
+ Updates an existing snapshot.
+ |
+
void |
+updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request,
+ io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)
+
+ Updates an existing subscription.
+ |
+
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReadyclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected SubscriberGrpc.SubscriberStub build(io.grpc.Channel channel, + io.grpc.CallOptions callOptions)+
build in class io.grpc.stub.AbstractStub<SubscriberGrpc.SubscriberStub>public void createSubscription(com.google.pubsub.v1.Subscription request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)+
+ Creates a subscription to a given topic. + If the subscription already exists, returns `ALREADY_EXISTS`. + If the corresponding topic doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this subscription on the same project as the topic, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Subscription object. + Note that for REST API requests, you must specify a name in the request. +
public void getSubscription(com.google.pubsub.v1.GetSubscriptionRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)+
+ Gets the configuration details of a subscription. +
public void updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Subscription> responseObserver)+
+ Updates an existing subscription. Note that certain properties of a + subscription, such as its topic, are not modifiable. + NOTE: The style guide requires body: "subscription" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public void listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSubscriptionsResponse> responseObserver)+
+ Lists matching subscriptions. +
public void deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Deletes an existing subscription. All messages retained in the subscription + are immediately dropped. Calls to `Pull` after deletion will return + `NOT_FOUND`. After a subscription is deleted, a new one may be created with + the same name, but the new one has no association with the old + subscription or its topic unless the same topic is specified. +
public void modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Modifies the ack deadline for a specific message. This method is useful + 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. Note that this does not modify the + subscription-level `ackDeadlineSeconds` used for subsequent messages. +
public void acknowledge(com.google.pubsub.v1.AcknowledgeRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Acknowledges the messages associated with the `ack_ids` in the + `AcknowledgeRequest`. The Pub/Sub system can remove the relevant messages + from the subscription. + Acknowledging a message whose ack deadline has expired may succeed, + but such a message may be redelivered later. Acknowledging a message more + than once will not result in an error. +
public void pull(com.google.pubsub.v1.PullRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.PullResponse> responseObserver)+
+ Pulls messages from the server. Returns an empty list if there are no + messages available in the backlog. The server may return `UNAVAILABLE` if + there are too many concurrent pull requests pending for the given + subscription. +
public io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullRequest> streamingPull(io.grpc.stub.StreamObserver<com.google.pubsub.v1.StreamingPullResponse> responseObserver)+
+ (EXPERIMENTAL) StreamingPull is an experimental feature. This RPC will + respond with UNIMPLEMENTED errors unless you have been invited to test + this feature. Contact cloud-pubsub@google.com with any questions. + Establishes a stream with the server, which sends messages down to the + client. The client streams acknowledgements and ack deadline modifications + back to the server. The server will close the stream and return the status + on any error. The server may close the stream with status `OK` to reassign + server-side resources, in which case, the client should re-establish the + stream. `UNAVAILABLE` may also be returned in the case of a transient error + (e.g., a server restart). These should also be retried by the client. Flow + control can be achieved by configuring the underlying RPC channel. +
public void modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Modifies the `PushConfig` for a specified subscription. + This may be used to change a push subscription to a pull one (signified by + an empty `PushConfig`) or vice versa, or change the endpoint URL and other + attributes of a push subscription. Messages will accumulate for delivery + continuously through the call regardless of changes to the `PushConfig`. +
public void listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSnapshotsResponse> responseObserver)+
+ Lists the existing snapshots. +
public void createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)+
+ Creates a snapshot from the requested subscription. + If the snapshot already exists, returns `ALREADY_EXISTS`. + If the requested subscription doesn't exist, returns `NOT_FOUND`. + If the name is not provided in the request, the server will assign a random + name for this snapshot on the same project as the subscription, conforming + to the + [resource name format](https://cloud.google.com/pubsub/docs/overview#names). + The generated name is populated in the returned Snapshot object. + Note that for REST API requests, you must specify a name in the request. +
public void updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.Snapshot> responseObserver)+
+ Updates an existing snapshot. Note that certain properties of a snapshot + are not modifiable. + NOTE: The style guide requires body: "snapshot" instead of body: "*". + Keeping the latter for internal consistency in V1, however it should be + corrected in V2. See + https://cloud.google.com/apis/design/standard_methods#update for details. +
public void deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest request, + io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)+
+ Removes an existing snapshot. All messages retained in the snapshot + are immediately dropped. After a snapshot is deleted, a new one may be + created with the same name, but the new one has no association with the old + snapshot or its subscription, unless the same subscription is specified. +
public void seek(com.google.pubsub.v1.SeekRequest request, + io.grpc.stub.StreamObserver<com.google.pubsub.v1.SeekResponse> responseObserver)+
+ Seeks an existing subscription to a point in time or to a given snapshot, + whichever is provided in the request. +
@Generated(value="by gRPC proto compiler (version 1.2.0)",
+ comments="Source: google/pubsub/v1/pubsub.proto")
+public final class SubscriberGrpc
+extends java.lang.Object
++ The service that an application uses to manipulate subscriptions and to + consume messages from a subscription via the `Pull` method. +
| Modifier and Type | +Class and Description | +
|---|---|
static class |
+SubscriberGrpc.SubscriberBlockingStub
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
static class |
+SubscriberGrpc.SubscriberFutureStub
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
static class |
+SubscriberGrpc.SubscriberImplBase
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
static class |
+SubscriberGrpc.SubscriberStub
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
| Modifier and Type | +Field and Description | +
|---|---|
static io.grpc.MethodDescriptor<com.google.pubsub.v1.AcknowledgeRequest,com.google.protobuf.Empty> |
+METHOD_ACKNOWLEDGE |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.CreateSnapshotRequest,com.google.pubsub.v1.Snapshot> |
+METHOD_CREATE_SNAPSHOT |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.Subscription,com.google.pubsub.v1.Subscription> |
+METHOD_CREATE_SUBSCRIPTION |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteSnapshotRequest,com.google.protobuf.Empty> |
+METHOD_DELETE_SNAPSHOT |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteSubscriptionRequest,com.google.protobuf.Empty> |
+METHOD_DELETE_SUBSCRIPTION |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.GetSubscriptionRequest,com.google.pubsub.v1.Subscription> |
+METHOD_GET_SUBSCRIPTION |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.ListSnapshotsRequest,com.google.pubsub.v1.ListSnapshotsResponse> |
+METHOD_LIST_SNAPSHOTS |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.ListSubscriptionsRequest,com.google.pubsub.v1.ListSubscriptionsResponse> |
+METHOD_LIST_SUBSCRIPTIONS |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.ModifyAckDeadlineRequest,com.google.protobuf.Empty> |
+METHOD_MODIFY_ACK_DEADLINE |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.ModifyPushConfigRequest,com.google.protobuf.Empty> |
+METHOD_MODIFY_PUSH_CONFIG |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.PullRequest,com.google.pubsub.v1.PullResponse> |
+METHOD_PULL |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.SeekRequest,com.google.pubsub.v1.SeekResponse> |
+METHOD_SEEK |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.StreamingPullRequest,com.google.pubsub.v1.StreamingPullResponse> |
+METHOD_STREAMING_PULL |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.UpdateSnapshotRequest,com.google.pubsub.v1.Snapshot> |
+METHOD_UPDATE_SNAPSHOT |
+
static io.grpc.MethodDescriptor<com.google.pubsub.v1.UpdateSubscriptionRequest,com.google.pubsub.v1.Subscription> |
+METHOD_UPDATE_SUBSCRIPTION |
+
static java.lang.String |
+SERVICE_NAME |
+
| Modifier and Type | +Method and Description | +
|---|---|
static io.grpc.ServiceDescriptor |
+getServiceDescriptor() |
+
static SubscriberGrpc.SubscriberBlockingStub |
+newBlockingStub(io.grpc.Channel channel)
+Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ |
+
static SubscriberGrpc.SubscriberFutureStub |
+newFutureStub(io.grpc.Channel channel)
+Creates a new ListenableFuture-style stub that supports unary and streaming output calls on the service
+ |
+
static SubscriberGrpc.SubscriberStub |
+newStub(io.grpc.Channel channel)
+Creates a new async stub that supports all call types for the service
+ |
+
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final java.lang.String SERVICE_NAME+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.Subscription,com.google.pubsub.v1.Subscription> METHOD_CREATE_SUBSCRIPTION+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.GetSubscriptionRequest,com.google.pubsub.v1.Subscription> METHOD_GET_SUBSCRIPTION+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.UpdateSubscriptionRequest,com.google.pubsub.v1.Subscription> METHOD_UPDATE_SUBSCRIPTION+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ListSubscriptionsRequest,com.google.pubsub.v1.ListSubscriptionsResponse> METHOD_LIST_SUBSCRIPTIONS+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteSubscriptionRequest,com.google.protobuf.Empty> METHOD_DELETE_SUBSCRIPTION+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ModifyAckDeadlineRequest,com.google.protobuf.Empty> METHOD_MODIFY_ACK_DEADLINE+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.AcknowledgeRequest,com.google.protobuf.Empty> METHOD_ACKNOWLEDGE+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.PullRequest,com.google.pubsub.v1.PullResponse> METHOD_PULL+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.StreamingPullRequest,com.google.pubsub.v1.StreamingPullResponse> METHOD_STREAMING_PULL+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ModifyPushConfigRequest,com.google.protobuf.Empty> METHOD_MODIFY_PUSH_CONFIG+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.ListSnapshotsRequest,com.google.pubsub.v1.ListSnapshotsResponse> METHOD_LIST_SNAPSHOTS+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.CreateSnapshotRequest,com.google.pubsub.v1.Snapshot> METHOD_CREATE_SNAPSHOT+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.UpdateSnapshotRequest,com.google.pubsub.v1.Snapshot> METHOD_UPDATE_SNAPSHOT+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.DeleteSnapshotRequest,com.google.protobuf.Empty> METHOD_DELETE_SNAPSHOT+
@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1901") +public static final io.grpc.MethodDescriptor<com.google.pubsub.v1.SeekRequest,com.google.pubsub.v1.SeekResponse> METHOD_SEEK+
public static SubscriberGrpc.SubscriberStub newStub(io.grpc.Channel channel)+
public static SubscriberGrpc.SubscriberBlockingStub newBlockingStub(io.grpc.Channel channel)+
public static SubscriberGrpc.SubscriberFutureStub newFutureStub(io.grpc.Channel channel)+
public static io.grpc.ServiceDescriptor getServiceDescriptor()+
| Class | +Description | +
|---|---|
| PublisherGrpc | +
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
| PublisherGrpc.PublisherBlockingStub | +
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
| PublisherGrpc.PublisherFutureStub | +
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
| PublisherGrpc.PublisherImplBase | +
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
| PublisherGrpc.PublisherStub | +
+
+ The service that an application uses to manipulate topics, and to send
+ messages to a topic.
+ |
+
| SubscriberGrpc | +
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
| SubscriberGrpc.SubscriberBlockingStub | +
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
| SubscriberGrpc.SubscriberFutureStub | +
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
| SubscriberGrpc.SubscriberImplBase | +
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
| SubscriberGrpc.SubscriberStub | +
+
+ The service that an application uses to manipulate subscriptions and to
+ consume messages from a subscription via the `Pull` method.
+ |
+
| Modifier and Type | +Constant Field | +Value | +
|---|---|---|
+
+public static final java.lang.String |
+SERVICE_NAME |
+"google.pubsub.v1.Publisher" |
+
| Modifier and Type | +Constant Field | +Value | +
|---|---|---|
+
+public static final java.lang.String |
+SERVICE_NAME |
+"google.pubsub.v1.Subscriber" |
+
Each package has a page that contains a list of its classes and interfaces, with a summary for each. This page can contain six categories:
+Each class, interface, nested class and nested interface has its own separate page. Each of these pages has three sections consisting of a class/interface description, summary tables, and detailed member descriptions:
+Each summary entry contains the first sentence from the detailed description for that item. The summary entries are alphabetical, while the detailed descriptions are in the order they appear in the source code. This preserves the logical groupings established by the programmer.
+Each annotation type has its own separate page with the following sections:
+Each enum has its own separate page with the following sections:
+There is a Class Hierarchy page for all packages, plus a hierarchy for each package. Each hierarchy page contains a list of classes and a list of interfaces. The classes are organized by inheritance structure starting with java.lang.Object. The interfaces do not inherit from java.lang.Object.
The Deprecated API page lists all of the API that have been deprecated. A deprecated API is not recommended for use, generally due to improvements, and a replacement API is usually given. Deprecated APIs may be removed in future implementations.
+The Index contains an alphabetic list of all classes, interfaces, constructors, methods, and fields.
+These links take you to the next or previous class, interface, package, or related page.
+These links show and hide the HTML frames. All pages are available with or without frames.
+The All Classes link shows all classes and interfaces except non-static nested types.
+Each serializable or externalizable class has a description of its serialization fields and methods. This information is of interest to re-implementors, not to developers using the API. While there is no link in the navigation bar, you can get to this information by going to any serialized class and clicking "Serialized Form" in the "See also" section of the class description.
+The Constant Field Values page lists the static final fields and their values.
+