Package com.google.pubsub.v1

Class PublisherGrpc.PublisherFutureStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<PublisherGrpc.PublisherFutureStub>
com.google.pubsub.v1.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 Details

    • build

      protected PublisherGrpc.PublisherFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<PublisherGrpc.PublisherFutureStub>

    • 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.

    • listTopics

      public com.google.common.util.concurrent.ListenableFuture<ListTopicsResponse> listTopics(ListTopicsRequest request)
       Lists matching topics.

    • listTopicSubscriptions

      public com.google.common.util.concurrent.ListenableFuture<ListTopicSubscriptionsResponse> listTopicSubscriptions(ListTopicSubscriptionsRequest request)
       Lists the names of the attached subscriptions on this 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.