Package io.smallrye.reactive.messaging.gcp.pubsub

Class PubSubManager

java.lang.Object

io.smallrye.reactive.messaging.gcp.pubsub.PubSubManager

@ApplicationScoped
public class PubSubManager
extends Object

Constructor Summary

Constructors

Constructor	Description
PubSubManager()

Method Summary

Modifier and Type	Method	Description
void	destroy()
com.google.cloud.pubsub.v1.Publisher	publisher(PubSubConfig config)
void	subscriber(PubSubConfig config, io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>> emitter)
com.google.cloud.pubsub.v1.SubscriptionAdminClient	subscriptionAdminClient(PubSubConfig config)
com.google.cloud.pubsub.v1.TopicAdminClient	topicAdminClient(PubSubConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubManager

public PubSubManager()

Method Detail

publisher

public com.google.cloud.pubsub.v1.Publisher publisher(PubSubConfig config)

subscriber

public void subscriber(PubSubConfig config,
                       io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>> emitter)

subscriptionAdminClient

public com.google.cloud.pubsub.v1.SubscriptionAdminClient subscriptionAdminClient(PubSubConfig config)

topicAdminClient

public com.google.cloud.pubsub.v1.TopicAdminClient topicAdminClient(PubSubConfig config)

destroy

@PreDestroy
public void destroy()