com.google.pubsub.v1

Interface PublisherGrpc.AsyncService

All Known Implementing Classes:

PublisherGrpc.PublisherImplBase

Enclosing class:

PublisherGrpc

public static interface PublisherGrpc.AsyncService

 The service that an application uses to manipulate topics, and to send
 messages to a topic.
 

Method Summary

Modifier and Type	Method and Description
default void	createTopic(Topic request, StreamObserver<Topic> responseObserver) Creates the given topic with the given name.
default void	deleteTopic(DeleteTopicRequest request, StreamObserver<com.google.protobuf.Empty> responseObserver) Deletes the topic with the given name.
default void	detachSubscription(DetachSubscriptionRequest request, StreamObserver<DetachSubscriptionResponse> responseObserver) Detaches a subscription from this topic.
default void	getTopic(GetTopicRequest request, StreamObserver<Topic> responseObserver) Gets the configuration of a topic.
default void	listTopics(ListTopicsRequest request, StreamObserver<ListTopicsResponse> responseObserver) Lists matching topics.
default void	listTopicSnapshots(ListTopicSnapshotsRequest request, StreamObserver<ListTopicSnapshotsResponse> responseObserver) Lists the names of the snapshots on this topic.
default void	listTopicSubscriptions(ListTopicSubscriptionsRequest request, StreamObserver<ListTopicSubscriptionsResponse> responseObserver) Lists the names of the attached subscriptions on this topic.
default void	publish(PublishRequest request, StreamObserver<PublishResponse> responseObserver) Adds one or more messages to the topic.
default void	updateTopic(UpdateTopicRequest request, StreamObserver<Topic> responseObserver) Updates an existing topic.

Method Detail

createTopic

default void createTopic(Topic request,
                         StreamObserver<Topic> responseObserver)

 Creates the given topic with the given name. See the [resource name rules]
 (https://cloud.google.com/pubsub/docs/admin#resource_names).
 

updateTopic

default void updateTopic(UpdateTopicRequest request,
                         StreamObserver<Topic> responseObserver)

 Updates an existing topic. Note that certain properties of a
 topic are not modifiable.
 

publish

default void publish(PublishRequest request,
                     StreamObserver<PublishResponse> responseObserver)

 Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
 does not exist.
 

getTopic

default void getTopic(GetTopicRequest request,
                      StreamObserver<Topic> responseObserver)

 Gets the configuration of a topic.
 

listTopics

default void listTopics(ListTopicsRequest request,
                        StreamObserver<ListTopicsResponse> responseObserver)

 Lists matching topics.
 

listTopicSubscriptions

default void listTopicSubscriptions(ListTopicSubscriptionsRequest request,
                                    StreamObserver<ListTopicSubscriptionsResponse> responseObserver)

 Lists the names of the attached subscriptions on this topic.
 

listTopicSnapshots

default void listTopicSnapshots(ListTopicSnapshotsRequest request,
                                StreamObserver<ListTopicSnapshotsResponse> responseObserver)

 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

default void deleteTopic(DeleteTopicRequest request,
                         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_`.
 

detachSubscription

default void detachSubscription(DetachSubscriptionRequest request,
                                StreamObserver<DetachSubscriptionResponse> responseObserver)

 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.