Package com.google.pubsub.v1

Class PublisherGrpc.PublisherFutureStub

  • Enclosing class:
    PublisherGrpc
    public static final class PublisherGrpc.PublisherFutureStub
extends io.grpc.stub.AbstractFutureStub<PublisherGrpc.PublisherFutureStub>
    A stub to allow clients to do ListenableFuture-style rpc calls to service Publisher. 
     The service that an application uses to manipulate topics, and to send
 messages to a topic.

    • Method Detail

      • createTopic

        public com.google.common.util.concurrent.ListenableFuture<Topic> createTopic​(Topic request)
         Creates the given topic with the given name. See the [resource name rules]
 (https://cloud.google.com/pubsub/docs/admin#resource_names).

      • updateTopic

        public com.google.common.util.concurrent.ListenableFuture<Topic> updateTopic​(UpdateTopicRequest request)
         Updates an existing topic. Note that certain properties of a
 topic are not modifiable.

      • publish

        public com.google.common.util.concurrent.ListenableFuture<PublishResponse> publish​(PublishRequest request)
         Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
 does not exist.

      • getTopic

        public com.google.common.util.concurrent.ListenableFuture<Topic> getTopic​(GetTopicRequest request)
         Gets the configuration of a topic.

      • listTopicSnapshots

        public com.google.common.util.concurrent.ListenableFuture<ListTopicSnapshotsResponse> listTopicSnapshots​(ListTopicSnapshotsRequest request)
         Lists the names of the snapshots on this topic. Snapshots are used in
 [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
 which allow you to manage message acknowledgments in bulk. That is, you can
 set the acknowledgment state of messages in an existing subscription to the
 state captured by a snapshot.

      • deleteTopic

        public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteTopic​(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_`.

      • detachSubscription

        public com.google.common.util.concurrent.ListenableFuture<DetachSubscriptionResponse> detachSubscription​(DetachSubscriptionRequest request)
         Detaches a subscription from this topic. All messages retained in the
 subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
 will return FAILED_PRECONDITION. If the subscription is a push
 subscription, pushes to the endpoint will stop.