com.google.cloud.pubsub.v1

Class OpenCensusUtil.OpenCensusMessageReceiver

java.lang.Object

com.google.cloud.pubsub.v1.OpenCensusUtil.OpenCensusMessageReceiver

All Implemented Interfaces:

MessageReceiver

Enclosing class:

OpenCensusUtil

public static class OpenCensusUtil.OpenCensusMessageReceiver
extends Object
implements MessageReceiver

Wrapper class for MessageReceiver that decodes any received trace and tag contexts and puts them in scope.

Constructor Summary

Constructors

Constructor and Description
OpenCensusMessageReceiver(MessageReceiver receiver)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenCensusMessageReceiver

public OpenCensusMessageReceiver(MessageReceiver receiver)

Method Detail

receiveMessage

public void receiveMessage(PubsubMessage message,
                           AckReplyConsumer consumer)

Description copied from interface: MessageReceiver

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 {@code MessageReceiver} passes all messages to a {@link 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();
         }
       }
     };

 

Specified by:

receiveMessage in interface MessageReceiver