com.google.cloud.pubsub.v1

Interface MessageReceiver

public interface MessageReceiver

This interface can be implemented by users of Subscriber to receive messages.

Method Summary

Modifier and Type	Method and Description
void	receiveMessage(com.google.pubsub.v1.PubsubMessage message, AckReplyConsumer consumer) Called when a message is received by the subscriber.

Method Detail

receiveMessage

void receiveMessage(com.google.pubsub.v1.PubsubMessage message,
                    AckReplyConsumer consumer)

Called when a message is received by the subscriber. The implementation must arrange for AckReplyConsumer.ack() or AckReplyConsumer.nack() to be called after processing the message.

This MessageReceiver passes all messages to a BlockingQueue. This method can be called concurrently from multiple threads, so it is important that the queue be thread-safe. This example is for illustration. Implementations may directly process messages instead of sending them to queues.

 
 MessageReceiver receiver = new MessageReceiver() {
   public void receiveMessage(final PubsubMessage message, final AckReplyConsumer consumer) {
     if (blockingQueue.offer(message)) {
       consumer.ack();
     } else {
       consumer.nack();
     }
   }
 };