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

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

getKind, newClient

Methods inherited from interface java.io.Closeable

close