Class OpenCensusUtil.OpenCensusMessageReceiver (1.126.6)

Version 1.126.6

• 1.134.1 (latest)
• 1.133.1
• 1.132.2
• 1.131.0
• 1.130.0
• 1.129.6
• 1.127.3
• 1.126.6
• 1.125.13
• 1.123.18
• 1.122.2
• 1.121.1
• 1.120.24
• 1.119.1
• 1.118.0
• 1.117.0
• 1.116.4
• 1.115.5

public static class OpenCensusUtil.OpenCensusMessageReceiver implements MessageReceiver

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

Inheritance

java.lang.Object > OpenCensusUtil.OpenCensusMessageReceiver

Implements

MessageReceiver

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

OpenCensusMessageReceiver(MessageReceiver receiver)

public OpenCensusMessageReceiver(MessageReceiver receiver)

Parameter
Name	Description
receiver	MessageReceiver

Methods

receiveMessage(PubsubMessage message, AckReplyConsumer consumer)

public void receiveMessage(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 {@code 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();
         }
       }
     };

 

Parameters
Name	Description
message	PubsubMessage
consumer	AckReplyConsumer