Package com.rabbitmq.client.observation

Class NoOpObservationCollector

java.lang.Object

com.rabbitmq.client.observation.NoOpObservationCollector

All Implemented Interfaces:

ObservationCollector

final class NoOpObservationCollector
extends java.lang.Object
implements ObservationCollector

Nested Class Summary

Nested classes/interfaces inherited from interface com.rabbitmq.client.observation.ObservationCollector

ObservationCollector.BasicGetCall, ObservationCollector.ConnectionInfo, ObservationCollector.PublishCall

Field Summary

Fields inherited from interface com.rabbitmq.client.observation.ObservationCollector

NO_OP

Constructor Summary

Constructors

Constructor	Description
NoOpObservationCollector()

Method Summary

Modifier and Type	Method	Description
Consumer	basicConsume(java.lang.String queue, java.lang.String consumerTag, Consumer consumer)	Decorate consumer registration.
GetResponse	basicGet(ObservationCollector.BasicGetCall call, java.lang.String queue)	Decorate message polling with basic.get.
void	publish(ObservationCollector.PublishCall call, AMQP.Basic.Publish publish, AMQP.BasicProperties properties, byte[] body, ObservationCollector.ConnectionInfo connectionInfo)	Decorate message publishing.

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpObservationCollector

NoOpObservationCollector()

Method Detail

publish

public void publish(ObservationCollector.PublishCall call,
                    AMQP.Basic.Publish publish,
                    AMQP.BasicProperties properties,
                    byte[] body,
                    ObservationCollector.ConnectionInfo connectionInfo)
             throws java.io.IOException

Description copied from interface: ObservationCollector

Decorate message publishing.

Implementations are expected to call ObservationCollector.publish( PublishCall, AMQP.Basic.Publish, AMQP.BasicProperties, byte[], ConnectionInfo) to make sure the message is actually sent.

Specified by:

publish in interface ObservationCollector

Throws:

java.io.IOException

basicConsume

public Consumer basicConsume(java.lang.String queue,
                             java.lang.String consumerTag,
                             Consumer consumer)

Description copied from interface: ObservationCollector

Decorate consumer registration.

Implementations are expected to decorate the appropriate Consumer callbacks. The original Consumer behavior should not be changed though.

Specified by:

basicConsume in interface ObservationCollector

Returns:

basicGet

public GetResponse basicGet(ObservationCollector.BasicGetCall call,
                            java.lang.String queue)

Description copied from interface: ObservationCollector

Decorate message polling with basic.get.

Implementations are expected to ObservationCollector.basicGet( BasicGetCall, String) and return the same result.

Specified by:

basicGet in interface ObservationCollector

Returns: