abstract class PublisherClient extends PublisherClientPowerApi with Publisher with PekkoGrpcClient
- Annotations
- @PekkoGrpcGenerated()
- Source
- PublisherClient.java
- Alphabetic
- By Inheritance
- PublisherClient
- PekkoGrpcClient
- Publisher
- PublisherClientPowerApi
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PublisherClient()
Abstract Value Members
- abstract def close(): CompletionStage[Done]
- Definition Classes
- PekkoGrpcClient
- abstract def closed(): CompletionStage[Done]
- Definition Classes
- PekkoGrpcClient
- abstract def createTopic(in: Topic): CompletionStage[Topic]
Creates the given topic with the given name.
Creates the given topic with the given name. See the [resource name rules] (https://cloud.google.com/pubsub/docs/admin#resource_names).
- Definition Classes
- Publisher
- abstract def deleteTopic(in: DeleteTopicRequest): CompletionStage[Empty]
Deletes the topic with the given name.
Deletes the topic with the given name. Returns
NOT_FOUNDif 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 theirtopicfield is set to_deleted-topic_.- Definition Classes
- Publisher
- abstract def detachSubscription(in: DetachSubscriptionRequest): CompletionStage[DetachSubscriptionResponse]
Detaches a subscription from this topic.
Detaches a subscription from this topic. All messages retained in the subscription are dropped. Subsequent
PullandStreamingPullrequests will return FAILED_PRECONDITION. If the subscription is a push subscription, pushes to the endpoint will stop.- Definition Classes
- Publisher
- abstract def getTopic(in: GetTopicRequest): CompletionStage[Topic]
Gets the configuration of a topic.
Gets the configuration of a topic.
- Definition Classes
- Publisher
- abstract def listTopicSnapshots(in: ListTopicSnapshotsRequest): CompletionStage[ListTopicSnapshotsResponse]
Lists the names of the snapshots on this topic.
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.
- Definition Classes
- Publisher
- abstract def listTopicSubscriptions(in: ListTopicSubscriptionsRequest): CompletionStage[ListTopicSubscriptionsResponse]
Lists the names of the attached subscriptions on this topic.
Lists the names of the attached subscriptions on this topic.
- Definition Classes
- Publisher
- abstract def listTopics(in: ListTopicsRequest): CompletionStage[ListTopicsResponse]
Lists matching topics.
Lists matching topics.
- Definition Classes
- Publisher
- abstract def publish(in: PublishRequest): CompletionStage[PublishResponse]
Adds one or more messages to the topic.
Adds one or more messages to the topic. Returns
NOT_FOUNDif the topic does not exist.- Definition Classes
- Publisher
- abstract def updateTopic(in: UpdateTopicRequest): CompletionStage[Topic]
Updates an existing topic.
Updates an existing topic. Note that certain properties of a topic are not modifiable.
- Definition Classes
- Publisher
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createTopic(): SingleResponseRequestBuilder[Topic, Topic]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer createTopic(com.google.pubsub.v1.Topic) if possible.
- Definition Classes
- PublisherClientPowerApi
- def deleteTopic(): SingleResponseRequestBuilder[DeleteTopicRequest, Empty]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer deleteTopic(com.google.pubsub.v1.DeleteTopicRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- def detachSubscription(): SingleResponseRequestBuilder[DetachSubscriptionRequest, DetachSubscriptionResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer detachSubscription(com.google.pubsub.v1.DetachSubscriptionRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getTopic(): SingleResponseRequestBuilder[GetTopicRequest, Topic]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer getTopic(com.google.pubsub.v1.GetTopicRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def listTopicSnapshots(): SingleResponseRequestBuilder[ListTopicSnapshotsRequest, ListTopicSnapshotsResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- def listTopicSubscriptions(): SingleResponseRequestBuilder[ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- def listTopics(): SingleResponseRequestBuilder[ListTopicsRequest, ListTopicsResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer listTopics(com.google.pubsub.v1.ListTopicsRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def publish(): SingleResponseRequestBuilder[PublishRequest, PublishResponse]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer publish(com.google.pubsub.v1.PublishRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def updateTopic(): SingleResponseRequestBuilder[UpdateTopicRequest, Topic]
Lower level "lifted" version of the method, giving access to request metadata etc.
Lower level "lifted" version of the method, giving access to request metadata etc. prefer updateTopic(com.google.pubsub.v1.UpdateTopicRequest) if possible.
- Definition Classes
- PublisherClientPowerApi
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()