com.google.cloud.examples.pubsub

Class PubSubExample

java.lang.Object

com.google.cloud.examples.pubsub.PubSubExample

public class PubSubExample
extends Object

An example of using Google BigQuery.

This example demonstrates a simple/typical Pub/Sub usage.

Steps needed for running the example:

1. login using gcloud SDK - gcloud auth login.
2. compile using maven - mvn compile
3. run using maven -

   mvn exec:java -Dexec.mainClass="com.google.cloud.examples.pubsub.PubSubExample"
     -Dexec.args="[<project_id>]
     pull async <subscription> <timeoutMillis>?
     pull sync <subscription> <maxMessages>
     publish <topic> <message>+
     replace-push-config <subscription> <endpoint>?
     ack <subscription> <ackId>+
     nack <subscription> <ackId>+
     create topic <topic>
     create subscription <topic> <subscription> <endpoint>?
     list subscriptions <topic>?
     list topics
     delete topic <topic>
     delete subscription <subscription>
     info topic <topic>
     info subscription <subscription>"

The first parameter is an optional project_id (logged-in project will be used if not supplied). Second parameter is a Pub/Sub operation and can be used to demonstrate its usage. For operations that apply to more than one entity (`list`, `create`, `info` and `delete`) the third parameter specifies the entity. `pull` operation also takes a third parameter to specify whether pulling should be synchronous or asynchronous.

Constructor Summary

Constructors

Constructor and Description
PubSubExample()

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(String... args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PubSubExample

public PubSubExample()

Method Detail

main

public static void main(String... args)
                 throws Exception

Throws:

Exception