Package com.google.cloud.pubsub

A client to Google Cloud Pub/Sub.

See: Description

Interface Summary

Interface	Description
PubSub	An interface for Google Cloud Pub/Sub.
PubSub.MessageConsumer	An interface to control a message consumer.
PubSub.MessageProcessor	A callback to process pulled messages.
PubSubFactory	An interface for Pub/Sub factories.

Class Summary

Class	Description
Message	A Google Cloud Pub/Sub message.
Message.Builder	Builder for Message objects.
PubSub.ListOption	Class for specifying options for listing topics and subscriptions.
PubSub.PullOption	Class for specifying options for pulling messages.
PubSubOptions
PubSubOptions.Builder
PubSubOptions.DefaultPubSubFactory
PubSubOptions.DefaultPubSubRpcFactory
PushConfig	Google Cloud Pub/Sub configuration for a push subscription.
PushConfig.Builder	Builder for PushConfig objects.
ReceivedMessage	A Google Cloud Pub/Sub received message.
ReceivedMessage.Builder
Subscription	A Google Cloud Pub/Sub subscription.
Subscription.Builder	A builder for Subscription objects.
SubscriptionId	Identity for a Google PubSub subscription.
SubscriptionInfo	A Google Cloud Pub/Sub subscription.
SubscriptionInfo.Builder	Builder for SubscriptionInfo objects.
Topic	A Google Cloud Pub/Sub topic.
Topic.Builder	A builder for Topic objects.
TopicId	Identity for a Google PubSub topic.
TopicInfo	A Google Cloud Pub/Sub topic.
TopicInfo.Builder	Builder for TopicInfo objects.

Exception Summary

Exception	Description
PubSubException	Pub/Sub service exception.

Package com.google.cloud.pubsub Description

A client to Google Cloud Pub/Sub.

Here's a simple usage example for using gcloud-java from Compute Engine/App Engine Flexible. This example shows how to create a Pub/Sub topic and asynchronously publish messages to it. For the complete source code see CreateTopicAndPublishMessages.java.

 try (PubSub pubsub = PubSubOptions.defaultInstance().service()) {
   Topic topic = pubsub.create(TopicInfo.of("test-topic"));
   Message message1 = Message.of("First message");
   Message message2 = Message.of("Second message");
   topic.publishAsync(message1, message2);
 }

This second example shows how to create a Pub/Sub pull subscription and asynchronously pull messages from it. For the complete source code see CreateSubscriptionAndPullMessages.java.

 try (PubSub pubsub = PubSubOptions.defaultInstance().service()) {
   Subscription subscription =
   pubsub.create(SubscriptionInfo.of("test-topic", "test-subscription"));
   MessageProcessor callback = new MessageProcessor() {
     public void process(Message message) throws Exception {
       System.out.printf("Received message \"%s\"%n", message.payloadAsString());
     }
   };
   // Create a message consumer and pull messages (for 60 seconds)
   try (MessageConsumer consumer = subscription.pullAsync(callback)) {
     Thread.sleep(60_000);
   }
 }

See Also:

Google Cloud Pub/Sub