- ack(String, String, String...) - Method in interface com.google.cloud.pubsub.PubSub
-
Acknowledges the given messages for the provided subscription.
- ack(String, Iterable<String>) - Method in interface com.google.cloud.pubsub.PubSub
-
Acknowledges the given messages for the provided subscription.
- ack() - Method in class com.google.cloud.pubsub.ReceivedMessage
-
Acknowledges the current message.
- ackAsync(String, String, String...) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request to acknowledge the given messages for the provided subscription.
- ackAsync(String, Iterable<String>) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request to acknowledge the given messages for the provided subscription.
- ackAsync() - Method in class com.google.cloud.pubsub.ReceivedMessage
-
Sends a request to acknowledge the current message.
- ackDeadLineSeconds(int) - Method in class com.google.cloud.pubsub.Subscription.Builder
-
- ackDeadlineSeconds() - Method in class com.google.cloud.pubsub.SubscriptionInfo
-
Returns the maximum time after a subscriber receives a message before the subscriber should
acknowledge the message.
- ackDeadLineSeconds(int) - Method in class com.google.cloud.pubsub.SubscriptionInfo.Builder
-
Sets the maximum time after a subscriber receives a message before the subscriber should
acknowledge the message.
- ackId() - Method in class com.google.cloud.pubsub.ReceivedMessage
-
Returns the acknowledge id of the message.
- acknowledge(AcknowledgeRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- acknowledge(AcknowledgeRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to acknowledge messages for a subscription.
- acknowledge(String, List<String>) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Acknowledges the messages associated with the `ack_ids` in the
`AcknowledgeRequest`.
- acknowledge(AcknowledgeRequest) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Acknowledges the messages associated with the `ack_ids` in the
`AcknowledgeRequest`.
- acknowledgeCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Acknowledges the messages associated with the `ack_ids` in the
`AcknowledgeRequest`.
- acknowledgeSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to acknowledge.
- acknowledgeSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to acknowledge.
- addAttribute(String, String) - Method in class com.google.cloud.pubsub.Message.Builder
-
Adds a new attribute to the message attributes.
- addAttribute(String, String) - Method in class com.google.cloud.pubsub.PushConfig.Builder
-
Adds an API-supported attribute that can be used to control different aspects of the message
delivery.
- addAttribute(String, String) - Method in class com.google.cloud.pubsub.ReceivedMessage.Builder
-
- addCallback(PubSubRpc.PullCallback) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc.PullFuture
-
Registers a callback to be run on the given executor.
- applyToAllApiMethods(ApiCallSettings.Builder) - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
Applies the given settings to all of the API methods in this service.
- applyToAllApiMethods(ApiCallSettings.Builder) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Applies the given settings to all of the API methods in this service.
- attributes() - Method in class com.google.cloud.pubsub.Message
-
Returns the message attributes.
- attributes(Map<String, String>) - Method in class com.google.cloud.pubsub.Message.Builder
-
Sets the message attributes to the provided map.
- attributes() - Method in class com.google.cloud.pubsub.PushConfig
-
Returns the API-supported attributes that can be used to control different aspects of the
message delivery.
- attributes(Map<String, String>) - Method in class com.google.cloud.pubsub.PushConfig.Builder
-
Sets the API-supported attributes that can be used to control different aspects of the
message delivery.
- attributes(Map<String, String>) - Method in class com.google.cloud.pubsub.ReceivedMessage.Builder
-
- clearAttributes() - Method in class com.google.cloud.pubsub.Message.Builder
-
Clears all message attributes.
- clearAttributes() - Method in class com.google.cloud.pubsub.PushConfig.Builder
-
Clears all API-supported attributes.
- clearAttributes() - Method in class com.google.cloud.pubsub.ReceivedMessage.Builder
-
- close() - Method in interface com.google.cloud.pubsub.PubSub.MessageConsumer
-
Stops pulling messages from the subscription associated with this MessageConsumer and
frees all resources.
- close() - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- close() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately
cancelled.
- close() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Initiates an orderly shutdown in which preexisting calls continue but new calls are immediately
cancelled.
- com.google.cloud.pubsub - package com.google.cloud.pubsub
-
A client to Google Cloud Pub/Sub.
- com.google.cloud.pubsub.spi - package com.google.cloud.pubsub.spi
-
- com.google.cloud.pubsub.spi.v1 - package com.google.cloud.pubsub.spi.v1
-
- com.google.cloud.pubsub.testing - package com.google.cloud.pubsub.testing
-
A testing helper for Google Cloud Pub/Sub.
- create(TopicInfo) - Method in interface com.google.cloud.pubsub.PubSub
-
Creates a new topic.
- create(SubscriptionInfo) - Method in interface com.google.cloud.pubsub.PubSub
-
Creates a new subscription.
- create(PubSubOptions) - Method in class com.google.cloud.pubsub.PubSubOptions.DefaultPubSubFactory
-
- create(PubSubOptions) - Method in class com.google.cloud.pubsub.PubSubOptions.DefaultPubSubRpcFactory
-
- create(Topic) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- create(Subscription) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- create(Topic) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to create a topic.
- create(Subscription) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to create a subscription.
- create(PublisherSettings) - Static method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Constructs an instance of PublisherApi, using the given settings.
- create(SubscriberSettings) - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Constructs an instance of SubscriberApi, using the given settings.
- create() - Static method in class com.google.cloud.pubsub.testing.LocalPubsubHelper
-
Constructs a new LocalPubsubHelper.
- createAsync(TopicInfo) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for creating a topic.
- createAsync(SubscriptionInfo) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for creating a subscription.
- createChannel() - Method in class com.google.cloud.pubsub.testing.LocalPubsubHelper
-
Creates a channel for making requests to the in-memory service.
- createSubscription(String, String, PushConfig, int) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Creates a subscription to a given topic for a given subscriber.
- createSubscription(Subscription) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Creates a subscription to a given topic for a given subscriber.
- createSubscriptionCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Creates a subscription to a given topic for a given subscriber.
- createSubscriptionSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to createSubscription.
- createSubscriptionSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to createSubscription.
- createTopic(String) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Creates the given topic with the given name.
- createTopicCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Creates the given topic with the given name.
- createTopicSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
Returns the builder for the settings used for calls to createTopic.
- createTopicSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns the object with the settings used for calls to createTopic.
- createWithDefaults() - Static method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Constructs an instance of PublisherApi with default settings.
- createWithDefaults() - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Constructs an instance of SubscriberApi with default settings.
- DEFAULT_CONNECTION_SETTINGS - Static variable in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
The default connection settings of the service.
- DEFAULT_CONNECTION_SETTINGS - Static variable in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
The default connection settings of the service.
- DEFAULT_SERVICE_ADDRESS - Static variable in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
The default address of the service.
- DEFAULT_SERVICE_ADDRESS - Static variable in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
The default address of the service.
- DEFAULT_SERVICE_PORT - Static variable in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
The default port of the service.
- DEFAULT_SERVICE_PORT - Static variable in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
The default port of the service.
- DEFAULT_SERVICE_SCOPES - Static variable in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
The default scopes of the service.
- DEFAULT_SERVICE_SCOPES - Static variable in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
The default scopes of the service.
- defaultBuilder() - Static method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns a builder for this class with recommended defaults.
- defaultBuilder() - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns a builder for this class with recommended defaults.
- defaultHost() - Method in class com.google.cloud.pubsub.PubSubOptions
-
- defaultInstance() - Static method in class com.google.cloud.pubsub.PubSubOptions
-
Returns a default PubSubOptions instance.
- DefaultPubSubRpc - Class in com.google.cloud.pubsub.spi
-
- DefaultPubSubRpc(PubSubOptions) - Constructor for class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- defaultRpcFactory() - Method in class com.google.cloud.pubsub.PubSubOptions
-
- defaultServiceFactory() - Method in class com.google.cloud.pubsub.PubSubOptions
-
- delete(DeleteTopicRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- delete(DeleteSubscriptionRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- delete(DeleteTopicRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to delete a topic.
- delete(DeleteSubscriptionRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to delete a subscription.
- delete() - Method in class com.google.cloud.pubsub.Subscription
-
Deletes this subscription.
- delete() - Method in class com.google.cloud.pubsub.Topic
-
Deletes this topic.
- deleteAsync() - Method in class com.google.cloud.pubsub.Subscription
-
Sends a request for deleting this subscription.
- deleteAsync() - Method in class com.google.cloud.pubsub.Topic
-
Sends a request for deleting this topic.
- deletedTopic() - Static method in class com.google.cloud.pubsub.TopicId
-
Returns the identity of a deleted topic.
- deleteSubscription(String) - Method in interface com.google.cloud.pubsub.PubSub
-
Deletes the requested subscription.
- deleteSubscription(String) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Deletes an existing subscription.
- deleteSubscriptionAsync(String) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for deleting a subscription.
- deleteSubscriptionCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Deletes an existing subscription.
- deleteSubscriptionSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to deleteSubscription.
- deleteSubscriptionSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to deleteSubscription.
- deleteTopic(String) - Method in interface com.google.cloud.pubsub.PubSub
-
Deletes the requested topic.
- deleteTopic(String) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Deletes the topic with the given name.
- deleteTopicAsync(String) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for deleting a topic.
- deleteTopicCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Deletes the topic with the given name.
- deleteTopicSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
Returns the builder for the settings used for calls to deleteTopic.
- deleteTopicSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns the object with the settings used for calls to deleteTopic.
- list(ListTopicsRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- list(ListTopicSubscriptionsRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- list(ListSubscriptionsRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- list(ListTopicsRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to list the topics in a project.
- list(ListTopicSubscriptionsRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to list the subscriptions for a topic.
- list(ListSubscriptionsRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to list the subscriptions in a project.
- listSubscriptions(PubSub.ListOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Lists the subscriptions.
- listSubscriptions(String, PubSub.ListOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Lists the identities of the subscriptions for the provided topic.
- listSubscriptions(String) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Lists matching subscriptions.
- listSubscriptions(ListSubscriptionsRequest) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Lists matching subscriptions.
- listSubscriptions(PubSub.ListOption...) - Method in class com.google.cloud.pubsub.Topic
-
Lists the identities of the subscriptions for this topic.
- listSubscriptionsAsync(PubSub.ListOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for listing subscriptions.
- listSubscriptionsAsync(String, PubSub.ListOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for listing the identities of subscriptions for the provided topic.
- listSubscriptionsAsync(PubSub.ListOption...) - Method in class com.google.cloud.pubsub.Topic
-
Sends a request for listing the identities of subscriptions for this topic.
- listSubscriptionsCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Lists matching subscriptions.
- listSubscriptionsPagedCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Lists matching subscriptions.
- listSubscriptionsSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to listSubscriptions.
- listSubscriptionsSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to listSubscriptions.
- listTopics(PubSub.ListOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Lists the topics.
- listTopics(String) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists matching topics.
- listTopics(ListTopicsRequest) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists matching topics.
- listTopicsAsync(PubSub.ListOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for listing topics.
- listTopicsCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists matching topics.
- listTopicsPagedCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists matching topics.
- listTopicsSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
Returns the builder for the settings used for calls to listTopics.
- listTopicsSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns the object with the settings used for calls to listTopics.
- listTopicSubscriptions(String) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists the name of the subscriptions for this topic.
- listTopicSubscriptions(ListTopicSubscriptionsRequest) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists the name of the subscriptions for this topic.
- listTopicSubscriptionsCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists the name of the subscriptions for this topic.
- listTopicSubscriptionsPagedCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Lists the name of the subscriptions for this topic.
- listTopicSubscriptionsSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
Returns the builder for the settings used for calls to listTopicSubscriptions.
- listTopicSubscriptionsSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns the object with the settings used for calls to listTopicSubscriptions.
- LocalPubsubHelper - Class in com.google.cloud.pubsub.testing
-
A class that runs a Pubsub emulator instance for use in tests.
- maxQueuedCallbacks(int) - Static method in class com.google.cloud.pubsub.PubSub.PullOption
-
Returns an option to specify the maximum number of messages that can be queued in the message
consumer at any time.
- Message - Class in com.google.cloud.pubsub
-
A Google Cloud Pub/Sub message.
- Message.Builder - Class in com.google.cloud.pubsub
-
Builder for Message objects.
- Message.Builder() - Constructor for class com.google.cloud.pubsub.Message.Builder
-
- modify(ModifyAckDeadlineRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- modify(ModifyPushConfigRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- modify(ModifyAckDeadlineRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to modify the acknowledge deadline of a subscription.
- modify(ModifyPushConfigRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to modify the push configuration of a subscription.
- modifyAckDeadline(String, int, TimeUnit, String, String...) - Method in interface com.google.cloud.pubsub.PubSub
-
Modifies the acknowledge deadline of the given messages.
- modifyAckDeadline(String, int, TimeUnit, Iterable<String>) - Method in interface com.google.cloud.pubsub.PubSub
-
Modifies the acknowledge deadline of the given messages.
- modifyAckDeadline(int, TimeUnit) - Method in class com.google.cloud.pubsub.ReceivedMessage
-
Modifies the acknowledge deadline of the current message.
- modifyAckDeadline(String, List<String>, int) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Modifies the ack deadline for a specific message.
- modifyAckDeadline(ModifyAckDeadlineRequest) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Modifies the ack deadline for a specific message.
- modifyAckDeadlineAsync(String, int, TimeUnit, String, String...) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request to modify the acknowledge deadline of the given messages.
- modifyAckDeadlineAsync(String, int, TimeUnit, Iterable<String>) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request to modify the acknowledge deadline of the given messages.
- modifyAckDeadlineAsync(int, TimeUnit) - Method in class com.google.cloud.pubsub.ReceivedMessage
-
Sends a request to modify the acknowledge deadline of the given messages.
- modifyAckDeadlineCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Modifies the ack deadline for a specific message.
- modifyAckDeadlineSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to modifyAckDeadline.
- modifyAckDeadlineSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to modifyAckDeadline.
- modifyPushConfig(String, PushConfig) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Modifies the `PushConfig` for a specified subscription.
- modifyPushConfig(ModifyPushConfigRequest) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Modifies the `PushConfig` for a specified subscription.
- modifyPushConfigCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Modifies the `PushConfig` for a specified subscription.
- modifyPushConfigSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to modifyPushConfig.
- modifyPushConfigSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to modifyPushConfig.
- pageSize(int) - Static method in class com.google.cloud.pubsub.PubSub.ListOption
-
Returns an option to specify the maximum number of resources returned per page.
- pageToken(String) - Static method in class com.google.cloud.pubsub.PubSub.ListOption
-
Returns an option to specify the page token from which to start listing resources.
- parseProjectFromProjectName(String) - Static method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Parses the project from the given fully-qualified path which
represents a project resource.
- parseProjectFromProjectName(String) - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Parses the project from the given fully-qualified path which
represents a project resource.
- parseProjectFromSubscriptionName(String) - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Parses the project from the given fully-qualified path which
represents a subscription resource.
- parseProjectFromTopicName(String) - Static method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Parses the project from the given fully-qualified path which
represents a topic resource.
- parseProjectFromTopicName(String) - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Parses the project from the given fully-qualified path which
represents a topic resource.
- parseSubscriptionFromSubscriptionName(String) - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Parses the subscription from the given fully-qualified path which
represents a subscription resource.
- parseTopicFromTopicName(String) - Static method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Parses the topic from the given fully-qualified path which
represents a topic resource.
- parseTopicFromTopicName(String) - Static method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Parses the topic from the given fully-qualified path which
represents a topic resource.
- payload(String) - Method in class com.google.cloud.pubsub.Message.Builder
-
Sets the message payload to the provided string.
- payload(ByteArray) - Method in class com.google.cloud.pubsub.Message.Builder
-
Sets the message payload to the provided
ByteArray.
- payload() - Method in class com.google.cloud.pubsub.Message
-
Returns the message payload.
- payload(String) - Method in class com.google.cloud.pubsub.ReceivedMessage.Builder
-
- payload(ByteArray) - Method in class com.google.cloud.pubsub.ReceivedMessage.Builder
-
- payloadAsString() - Method in class com.google.cloud.pubsub.Message
-
Returns the message payload as a string, decoded using UTF-8.
- process(Message) - Method in interface com.google.cloud.pubsub.PubSub.MessageProcessor
-
Processes the received message.
- project() - Method in class com.google.cloud.pubsub.SubscriptionId
-
Returns the name of the project where the subscription resides.
- project() - Method in class com.google.cloud.pubsub.TopicId
-
Returns the name of the project where the topic resides.
- provideChannelWith(ManagedChannel, boolean) - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
- provideChannelWith(ConnectionSettings) - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
- provideChannelWith(Credentials) - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
- provideChannelWith(List<String>) - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
- provideChannelWith(ManagedChannel, boolean) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
- provideChannelWith(ConnectionSettings) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
- provideChannelWith(Credentials) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
- provideChannelWith(List<String>) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
- provideExecutorWith(ScheduledExecutorService, boolean) - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
- provideExecutorWith(ScheduledExecutorService, boolean) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
- publish(String, Message) - Method in interface com.google.cloud.pubsub.PubSub
-
Publishes a message to the provided topic.
- publish(String, Message, Message...) - Method in interface com.google.cloud.pubsub.PubSub
-
Publishes a number of messages to the provided topic.
- publish(String, Iterable<Message>) - Method in interface com.google.cloud.pubsub.PubSub
-
Publishes a number of messages to the provided topic.
- publish(PublishRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- publish(PublishRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to publish messages.
- publish(String, List<PubsubMessage>) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Adds one or more messages to the topic.
- publish(PublishRequest) - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Adds one or more messages to the topic.
- publish(Message) - Method in class com.google.cloud.pubsub.Topic
-
Publishes a message to this topic.
- publish(Message, Message...) - Method in class com.google.cloud.pubsub.Topic
-
Publishes a number of messages to this topic.
- publish(Iterable<Message>) - Method in class com.google.cloud.pubsub.Topic
-
Publishes a number of messages to this topic.
- publishAsync(String, Message) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for publishing a message to the provided topic.
- publishAsync(String, Message, Message...) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request to publish a number of messages to the provided topic.
- publishAsync(String, Iterable<Message>) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request to publish a number of messages to the provided topic.
- publishAsync(Message) - Method in class com.google.cloud.pubsub.Topic
-
Sends a request for publishing a message to the this topic.
- publishAsync(Message, Message...) - Method in class com.google.cloud.pubsub.Topic
-
Sends a request to publish a number of messages to this topic.
- publishAsync(Iterable<Message>) - Method in class com.google.cloud.pubsub.Topic
-
Sends a request to publish a number of messages to this topic.
- publishCallable() - Method in class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Adds one or more messages to the topic.
- PublisherApi - Class in com.google.cloud.pubsub.spi.v1
-
Service Description: The service that an application uses to manipulate topics, and to send
messages to a topic.
- PublisherApi(PublisherSettings) - Constructor for class com.google.cloud.pubsub.spi.v1.PublisherApi
-
Constructs an instance of PublisherApi, using the given settings.
- PublisherSettings - Class in com.google.cloud.pubsub.spi.v1
-
- PublisherSettings.Builder - Class in com.google.cloud.pubsub.spi.v1
-
Builder for PublisherSettings.
- publishSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings.Builder
-
Returns the builder for the settings used for calls to publish.
- publishSettings() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns the object with the settings used for calls to publish.
- publishTime() - Method in class com.google.cloud.pubsub.Message
-
Returns the time in milliseconds at which the message was published.
- PubSub - Interface in com.google.cloud.pubsub
-
An interface for Google Cloud Pub/Sub.
- pubsub() - Method in class com.google.cloud.pubsub.ReceivedMessage
-
Returns the received message's PubSub object used to issue requests.
- pubSub() - Method in class com.google.cloud.pubsub.Subscription
-
Returns the subscription's PubSub object used to issue requests.
- pubSub() - Method in class com.google.cloud.pubsub.Topic
-
Returns the topic's PubSub object used to issue requests.
- PubSub.ListOption - Class in com.google.cloud.pubsub
-
Class for specifying options for listing topics and subscriptions.
- PubSub.MessageConsumer - Interface in com.google.cloud.pubsub
-
An interface to control a message consumer.
- PubSub.MessageProcessor - Interface in com.google.cloud.pubsub
-
A callback to process pulled messages.
- PubSub.PullOption - Class in com.google.cloud.pubsub
-
Class for specifying options for pulling messages.
- PubSubException - Exception in com.google.cloud.pubsub
-
Pub/Sub service exception.
- PubSubException(IOException, boolean) - Constructor for exception com.google.cloud.pubsub.PubSubException
-
- PubSubException(ApiException, boolean) - Constructor for exception com.google.cloud.pubsub.PubSubException
-
- PubSubFactory - Interface in com.google.cloud.pubsub
-
An interface for Pub/Sub factories.
- PubSubOptions - Class in com.google.cloud.pubsub
-
- PubSubOptions(PubSubOptions.Builder) - Constructor for class com.google.cloud.pubsub.PubSubOptions
-
- PubSubOptions.Builder - Class in com.google.cloud.pubsub
-
- PubSubOptions.DefaultPubSubFactory - Class in com.google.cloud.pubsub
-
- PubSubOptions.DefaultPubSubFactory() - Constructor for class com.google.cloud.pubsub.PubSubOptions.DefaultPubSubFactory
-
- PubSubOptions.DefaultPubSubRpcFactory - Class in com.google.cloud.pubsub
-
- PubSubOptions.DefaultPubSubRpcFactory() - Constructor for class com.google.cloud.pubsub.PubSubOptions.DefaultPubSubRpcFactory
-
- PubSubRpc - Interface in com.google.cloud.pubsub.spi
-
- PubSubRpc.PullCallback - Interface in com.google.cloud.pubsub.spi
-
- PubSubRpc.PullFuture - Interface in com.google.cloud.pubsub.spi
-
A
Future implementation for pull RPCs.
- PubSubRpcFactory - Interface in com.google.cloud.pubsub.spi
-
An interface for Pub/Sub RPC factory.
- pull(String, int) - Method in interface com.google.cloud.pubsub.PubSub
-
Pulls messages from the provided subscription.
- pull(PullRequest) - Method in class com.google.cloud.pubsub.spi.DefaultPubSubRpc
-
- pull(PullRequest) - Method in interface com.google.cloud.pubsub.spi.PubSubRpc
-
Sends a request to pull messages from a subscription.
- pull(String, boolean, int) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Pulls messages from the server.
- pull(PullRequest) - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Pulls messages from the server.
- pull(int) - Method in class com.google.cloud.pubsub.Subscription
-
Pulls messages from this subscription.
- pullAsync(String, int) - Method in interface com.google.cloud.pubsub.PubSub
-
Sends a request for pulling messages from the provided subscription.
- pullAsync(String, PubSub.MessageProcessor, PubSub.PullOption...) - Method in interface com.google.cloud.pubsub.PubSub
-
Creates a message consumer that pulls messages from the provided subscription.
- pullAsync(int) - Method in class com.google.cloud.pubsub.Subscription
-
Sends a request for pulling messages from this subscription.
- pullAsync(PubSub.MessageProcessor, PubSub.PullOption...) - Method in class com.google.cloud.pubsub.Subscription
-
Creates a message consumer that pulls messages from this subscription.
- pullCallable() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberApi
-
Pulls messages from the server.
- pullSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings.Builder
-
Returns the builder for the settings used for calls to pull.
- pullSettings() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns the object with the settings used for calls to pull.
- PushConfig - Class in com.google.cloud.pubsub
-
Google Cloud Pub/Sub configuration for a push subscription.
- pushConfig(PushConfig) - Method in class com.google.cloud.pubsub.Subscription.Builder
-
- pushConfig(PushConfig) - Method in class com.google.cloud.pubsub.SubscriptionInfo.Builder
-
Sets the push configuration for the subscription.
- pushConfig() - Method in class com.google.cloud.pubsub.SubscriptionInfo
-
Returns the push configuration for the subscription.
- PushConfig.Builder - Class in com.google.cloud.pubsub
-
Builder for PushConfig objects.
- toBuilder() - Method in class com.google.cloud.pubsub.Message
-
Returns a builder for the message object.
- toBuilder() - Method in class com.google.cloud.pubsub.PubSubOptions
-
- toBuilder() - Method in class com.google.cloud.pubsub.PushConfig
-
Returns a builder for the PushConfig object.
- toBuilder() - Method in class com.google.cloud.pubsub.ReceivedMessage
-
- toBuilder() - Method in class com.google.cloud.pubsub.spi.v1.PublisherSettings
-
Returns a builder containing all the values of this settings class.
- toBuilder() - Method in class com.google.cloud.pubsub.spi.v1.SubscriberSettings
-
Returns a builder containing all the values of this settings class.
- toBuilder() - Method in class com.google.cloud.pubsub.Subscription
-
- toBuilder() - Method in class com.google.cloud.pubsub.SubscriptionInfo
-
Returns a builder for the subscription object.
- toBuilder() - Method in class com.google.cloud.pubsub.Topic
-
- toBuilder() - Method in class com.google.cloud.pubsub.TopicInfo
-
Returns a builder for the topic object.
- topic(TopicId) - Method in class com.google.cloud.pubsub.Subscription.Builder
-
- topic(String, String) - Method in class com.google.cloud.pubsub.Subscription.Builder
-
- topic(String) - Method in class com.google.cloud.pubsub.Subscription.Builder
-
- topic(String) - Method in class com.google.cloud.pubsub.SubscriptionInfo.Builder
-
Sets the topic the subscription refers to, given the topic name.
- topic(String, String) - Method in class com.google.cloud.pubsub.SubscriptionInfo.Builder
-
Sets the topic the subscription refers to, given the project and topic names.
- topic(TopicId) - Method in class com.google.cloud.pubsub.SubscriptionInfo.Builder
-
Sets the topic the subscription refers to, given the topic identity.
- topic() - Method in class com.google.cloud.pubsub.SubscriptionInfo
-
Returns the identity of the topic this subscription refers to.
- Topic - Class in com.google.cloud.pubsub
-
A Google Cloud Pub/Sub topic.
- topic() - Method in class com.google.cloud.pubsub.TopicId
-
Returns the name of the topic.
- Topic.Builder - Class in com.google.cloud.pubsub
-
A builder for Topic objects.
- TopicId - Class in com.google.cloud.pubsub
-
Identity for a Google PubSub topic.
- TopicInfo - Class in com.google.cloud.pubsub
-
A Google Cloud Pub/Sub topic.
- TopicInfo.Builder - Class in com.google.cloud.pubsub
-
Builder for TopicInfo objects.
- TopicInfo.Builder() - Constructor for class com.google.cloud.pubsub.TopicInfo.Builder
-
- toString() - Method in class com.google.cloud.pubsub.Message
-
- toString() - Method in class com.google.cloud.pubsub.PushConfig
-
- toString() - Method in class com.google.cloud.pubsub.SubscriptionId
-
- toString() - Method in class com.google.cloud.pubsub.SubscriptionInfo
-
- toString() - Method in class com.google.cloud.pubsub.TopicId
-
- toString() - Method in class com.google.cloud.pubsub.TopicInfo
-