Skip to content
Branch: master
Find file History

Google Cloud Java Client for Pub/Sub

Java idiomatic client for Google Cloud Pub/Sub.

Kokoro CI Maven Codacy Badge


Add this to your pom.xml file


If you are using Gradle, add this to your dependencies

compile ''

If you are using SBT, add this to your dependencies

libraryDependencies += "" % "google-cloud-pubsub" % "1.97.0"


See the Authentication section in the base directory's README.

About Google Cloud Pub/Sub

Google Cloud Pub/Sub is designed to provide reliable, many-to-many, asynchronous messaging between applications. Publisher applications can send messages to a topic and other applications can subscribe to that topic to receive the messages. By decoupling senders and receivers, Google Cloud Pub/Sub allows developers to communicate between independently written applications.

See the Google Cloud Pub/Sub docs for more details on how to activate Cloud Pub/Sub for your project.

See the Pub/Sub client library docs to learn how to interact with the Cloud Pub/Sub using this Client Library.

Getting Started


For this tutorial, you will need a Google Developers Console project with the Pub/Sub API enabled. You will need to enable billing to use Google Cloud Pub/Sub. Follow these instructions to get your project set up. You will also need to set up the local development environment by installing the Google Cloud SDK and running the following commands in command line: gcloud auth login and gcloud config set project [YOUR PROJECT ID].

Installation and setup

You'll need to obtain the google-cloud-pubsub library. See the Quickstart section to add google-cloud-pubsub as a dependency in your code.

Creating an authorized service object

To make authenticated requests to Google Cloud Pub/Sub, you must create a service object with credentials. You can then make API calls by calling methods on the Pub/Sub service object. The simplest way to authenticate is to use Application Default Credentials. These credentials are automatically inferred from your environment.

For other authentication options, see the Authentication page.

Creating a topic

With Pub/Sub you can create topics. A topic is a named resource to which messages are sent by publishers. Add the following imports at the top of your file:


Then, to create the topic, use the following code:

ProjectTopicName topic = ProjectTopicName.of("test-project", "test-topic");
try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {

Publishing messages

With Pub/Sub you can publish messages to a topic. Add the following import at the top of your file:


Then, to publish messages asynchronously, use the following code:

Publisher publisher = null;
try {
  publisher = Publisher.newBuilder(topic).build();
  ByteString data = ByteString.copyFromUtf8("my-message");
  PubsubMessage pubsubMessage = PubsubMessage.newBuilder().setData(data).build();
  ApiFuture<String> messageIdFuture = publisher.publish(pubsubMessage);
} finally {
  if (publisher != null) {
    publisher.awaitTermination(1, TimeUnit.MINUTES);

Creating a subscription

With Pub/Sub you can create subscriptions. A subscription represents the stream of messages from a single, specific topic. Add the following imports at the top of your file:


Then, to create the subscription, use the following code:

ProjectTopicName topic = ProjectTopicName.of("test-project", "test-topic");
ProjectSubscriptionName subscription = ProjectSubscriptionName.of("test-project", "test-subscription");

try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
  subscriptionAdminClient.createSubscription(subscription, topic, PushConfig.getDefaultInstance(), 0);

Pulling messages

With Pub/Sub you can pull messages from a subscription. Add the following imports at the top of your file:


Then, to pull messages asynchronously, use the following code:

ProjectSubscriptionName subscription = ProjectSubscriptionName.of("test-project", "test-subscription");

MessageReceiver receiver =
  new MessageReceiver() {
    public void receiveMessage(PubsubMessage message, AckReplyConsumer consumer) {
      System.out.println("got message: " + message.getData().toStringUtf8());

Subscriber subscriber = null;
try {
  subscriber = Subscriber.newBuilder(subscription, receiver).build();
    new Subscriber.Listener() {
      public void failed(Subscriber.State from, Throwable failure) {
        // Handle failure. This is called when the Subscriber encountered a fatal error and is shutting down.
} finally {
  if (subscriber != null) {

Complete source code

In and we put together all the code shown above into two programs. The programs assume that you are running on Compute Engine, App Engine Flexible or from your own desktop.


Pub/Sub uses gRPC for the transport layer.

Java Versions

Java 7 or above is required for using this client.


This library has tools to help make tests for code using Cloud Pub/Sub.

See TESTING to read more about testing.


This library follows Semantic Versioning.

It is currently in major version one (1.y.z), which means that the public API should be considered stable.


Contributions to this library are always welcome and highly encouraged.

See google-cloud's CONTRIBUTING documentation and the shared documentation for more information on how to get started.

Please note that this project is released with a Contributor Code of Conduct. By participating in this project you agree to abide by its terms. See Code of Conduct for more information.


Apache 2.0 - See LICENSE for more information.

You can’t perform that action at this time.