com.google.cloud.pubsub.testing

Class LocalPubsubHelper

java.lang.Object

com.google.cloud.pubsub.testing.LocalPubsubHelper

public class LocalPubsubHelper
extends Object

A class that runs a Pubsub emulator instance for use in tests.

Method Summary

Methods

Modifier and Type	Method and Description
static LocalPubsubHelper	create() Constructs a new LocalPubsubHelper.
io.grpc.ManagedChannel	createChannel() Creates a channel for making requests to the in-memory service.
PubSubOptions	options() Returns a PubSubOptions instance that sets the host to use the PubSub emulator on localhost.
void	reset() Reset the internal state of the emulator.
void	start() Start the local pubsub emulator through gcloud, download the zip file if user does not have gcloud installed.
void	stop() Quit the local emulator and related local service.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static LocalPubsubHelper create()

Constructs a new LocalPubsubHelper. The method start() must be called before it is used.

start

public void start()
           throws IOException,
                  InterruptedException

Start the local pubsub emulator through gcloud, download the zip file if user does not have gcloud installed.

Throws:

InterruptedException

IOException

reset

public void reset()
           throws IOException

Reset the internal state of the emulator.

Throws:

IOException

stop

public void stop()
          throws IOException,
                 InterruptedException

Quit the local emulator and related local service.

Throws:

InterruptedException

IOException

createChannel

public io.grpc.ManagedChannel createChannel()

Creates a channel for making requests to the in-memory service.

options

public PubSubOptions options()

Returns a PubSubOptions instance that sets the host to use the PubSub emulator on localhost.