org.apache.beam.it.gcp.pubsub.conditions

Class PubsubMessagesCheck

java.lang.Object

org.apache.beam.it.conditions.ConditionCheck

org.apache.beam.it.gcp.pubsub.conditions.PubsubMessagesCheck

All Implemented Interfaces:

java.util.function.Supplier<java.lang.Boolean>

public abstract class PubsubMessagesCheck
extends ConditionCheck

ConditionCheck to validate if Pub/Sub has received a certain amount of messages.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubsubMessagesCheck.Builder Builder for PubsubMessagesCheck.

Nested classes/interfaces inherited from class org.apache.beam.it.conditions.ConditionCheck

ConditionCheck.CheckResult

Constructor Summary

Constructors

Constructor and Description
PubsubMessagesCheck()

Method Summary

Modifier and Type	Method and Description
static PubsubMessagesCheck.Builder	builder(PubsubResourceManager resourceManager, com.google.pubsub.v1.SubscriptionName subscription)
ConditionCheck.CheckResult	check()
java.lang.String	getDescription()
java.util.List<com.google.pubsub.v1.ReceivedMessage>	getReceivedMessageList()

Methods inherited from class org.apache.beam.it.conditions.ConditionCheck

and, get

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubMessagesCheck

public PubsubMessagesCheck()

Method Detail

getDescription

public java.lang.String getDescription()

Specified by:

getDescription in class ConditionCheck

check

public ConditionCheck.CheckResult check()

Specified by:

check in class ConditionCheck

builder

public static PubsubMessagesCheck.Builder builder(PubsubResourceManager resourceManager,
                                                  com.google.pubsub.v1.SubscriptionName subscription)

getReceivedMessageList

public java.util.List<com.google.pubsub.v1.ReceivedMessage> getReceivedMessageList()