org.apache.beam.sdk.io.gcp.pubsub

Interface PubsubTestClient.PubsubTestClientFactory

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, PubsubClient.PubsubClientFactory, java.io.Serializable

Enclosing class:

PubsubTestClient

public static interface PubsubTestClient.PubsubTestClientFactory
extends PubsubClient.PubsubClientFactory, java.io.Closeable, java.io.Serializable

Closing the factory will validate all expected messages were processed.

Method Summary

Modifier and Type	Method and Description
default <T> PubsubIO.Read<T>	setClock(PubsubIO.Read<T> readTransform, com.google.api.client.util.Clock clock)

Methods inherited from interface org.apache.beam.sdk.io.gcp.pubsub.PubsubClient.PubsubClientFactory

getKind, newClient, newClient

Methods inherited from interface java.io.Closeable

close

Method Detail

setClock

default <T> PubsubIO.Read<T> setClock(PubsubIO.Read<T> readTransform,
                                      com.google.api.client.util.Clock clock)