Package com.google.pubsub.v1
Class PublisherGrpc.PublisherBlockingStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractBlockingStub<PublisherGrpc.PublisherBlockingStub>
-
- com.google.pubsub.v1.PublisherGrpc.PublisherBlockingStub
-
- Enclosing class:
- PublisherGrpc
public static final class PublisherGrpc.PublisherBlockingStub extends io.grpc.stub.AbstractBlockingStub<PublisherGrpc.PublisherBlockingStub>
A stub to allow clients to do synchronous rpc calls to service Publisher.The service that an application uses to manipulate topics, and to send messages to a topic.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected PublisherGrpc.PublisherBlockingStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions)TopiccreateTopic(Topic request)Creates the given topic with the given name.com.google.protobuf.EmptydeleteTopic(DeleteTopicRequest request)Deletes the topic with the given name.DetachSubscriptionResponsedetachSubscription(DetachSubscriptionRequest request)Detaches a subscription from this topic.TopicgetTopic(GetTopicRequest request)Gets the configuration of a topic.ListTopicsResponselistTopics(ListTopicsRequest request)Lists matching topics.ListTopicSnapshotsResponselistTopicSnapshots(ListTopicSnapshotsRequest request)Lists the names of the snapshots on this topic.ListTopicSubscriptionsResponselistTopicSubscriptions(ListTopicSubscriptionsRequest request)Lists the names of the attached subscriptions on this topic.PublishResponsepublish(PublishRequest request)Adds one or more messages to the topic.TopicupdateTopic(UpdateTopicRequest request)Updates an existing topic.
-
-
-
Method Detail
-
build
protected PublisherGrpc.PublisherBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
buildin classio.grpc.stub.AbstractStub<PublisherGrpc.PublisherBlockingStub>
-
createTopic
public 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 Topic updateTopic(UpdateTopicRequest request)
Updates an existing topic. Note that certain properties of a topic are not modifiable.
-
publish
public PublishResponse publish(PublishRequest request)
Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic does not exist.
-
getTopic
public Topic getTopic(GetTopicRequest request)
Gets the configuration of a topic.
-
listTopics
public ListTopicsResponse listTopics(ListTopicsRequest request)
Lists matching topics.
-
listTopicSubscriptions
public ListTopicSubscriptionsResponse listTopicSubscriptions(ListTopicSubscriptionsRequest request)
Lists the names of the attached subscriptions on this topic.
-
listTopicSnapshots
public 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.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 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.
-
-