[Google Cloud Pub/Sub][pubsub] is a fully-managed real-time messaging service that allows you to

send and receive messages between independent applications.

These sample Java applications demonstrate how to access the Pub/Sub API using

the [Google Cloud Client Library for Java][google-cloud-java].

[pubsub]: https://cloud.google.com/pubsub/

[google-cloud-java]: https://github.com/GoogleCloudPlatform/google-cloud-java

Install [Maven](http://maven.apache.org/).

Build your project with:

mvn clean package -DskipTests

You can then run a given `ClassName` via:

mvn exec:java -Dexec.mainClass=com.example.pubsub.ClassName \

-DpropertyName=propertyValue \

-Dexec.args="any arguments to the app"

mvn exec:java -Dexec.mainClass=com.example.pubsub.QuickstartSample

<!-- Test dependencies -->

<dependency>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

<version>4.12</version>

<scope>test</scope>

</dependency>

<dependency>

<groupId>com.google.truth</groupId>

<artifactId>truth</artifactId>

<version>0.30</version>

<scope>test</scope>

</dependency>

package com.example.pubsub;

import static com.google.common.truth.Truth.assertThat;

import com.google.cloud.pubsub.PubSub;

import com.google.cloud.pubsub.PubSubOptions;

import org.junit.After;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.junit.runners.JUnit4;

import java.io.ByteArrayOutputStream;

import java.io.PrintStream;

@RunWith(JUnit4.class)

@SuppressWarnings("checkstyle:abbreviationaswordinname")

public class QuickstartSampleIT {

private ByteArrayOutputStream bout;

private PrintStream out;

private static final void deleteTestTopic() {

PubSub pubsub = PubSubOptions.defaultInstance().service();

String topicName = "my-new-topic";

pubsub.deleteTopic(topicName);

}

@Before

public void setUp() {

deleteTestTopic();

bout = new ByteArrayOutputStream();

out = new PrintStream(bout);

System.setOut(out);

}

@After

public void tearDown() {

System.setOut(null);

deleteTestTopic();

}

@Test

public void testQuickstart() throws Exception {

QuickstartSample.main();

String got = bout.toString();

assertThat(got).contains("Topic my-new-topic created.");

}

}