Package software.tnb.google.cloud.pubsub.validation

Class PubSubValidation

java.lang.Object

software.tnb.google.cloud.pubsub.validation.PubSubValidation

public class PubSubValidation
extends Object

Constructor Summary

Constructors

Constructor	Description
PubSubValidation(com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient, com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient, com.google.api.gax.core.CredentialsProvider credsProvider, String projectId)

Method Summary

Modifier and Type	Method	Description
com.google.pubsub.v1.Subscription	createNewSubscription(String subscriptionId, String topicId)
com.google.pubsub.v1.Topic	createNewTopic(String topicId)
void	deleteSubscription(String subscriptionId)
void	deleteTopic(String topicId)
void	publishMessage(String topicId, String message)
List<com.google.pubsub.v1.PubsubMessage>	receiveMessageFor(int seconds, String subscriptionId)	will listen on the specified subscription for specified duration of seconds

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubValidation

public PubSubValidation(com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient,
                        com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient,
                        com.google.api.gax.core.CredentialsProvider credsProvider,
                        String projectId)

Method Detail

createNewTopic

public com.google.pubsub.v1.Topic createNewTopic(String topicId)

deleteTopic

public void deleteTopic(String topicId)

createNewSubscription

public com.google.pubsub.v1.Subscription createNewSubscription(String subscriptionId,
                                                               String topicId)

deleteSubscription

public void deleteSubscription(String subscriptionId)

publishMessage

public void publishMessage(String topicId,
                           String message)

receiveMessageFor

public List<com.google.pubsub.v1.PubsubMessage> receiveMessageFor(int seconds,
                                                                  String subscriptionId)

will listen on the specified subscription for specified duration of seconds

Parameters:

seconds -

subscriptionId -

Returns: