io.smallrye.reactive.messaging.gcp.pubsub

Class PubSubMessageReceiver

java.lang.Object

io.smallrye.reactive.messaging.gcp.pubsub.PubSubMessageReceiver

All Implemented Interfaces:

com.google.cloud.pubsub.v1.MessageReceiver

public class PubSubMessageReceiver
extends Object
implements com.google.cloud.pubsub.v1.MessageReceiver

Constructor Summary

Constructors

Constructor and Description
PubSubMessageReceiver(io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>> emitter)

Method Summary

Modifier and Type	Method and Description
void	receiveMessage(com.google.pubsub.v1.PubsubMessage message, com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubMessageReceiver

public PubSubMessageReceiver(io.smallrye.mutiny.subscription.MultiEmitter<? super Message<?>> emitter)

Method Detail

receiveMessage

public void receiveMessage(com.google.pubsub.v1.PubsubMessage message,
                           com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)

Specified by:

receiveMessage in interface com.google.cloud.pubsub.v1.MessageReceiver