Class NoOpObservationCollector

java.lang.Object

com.rabbitmq.client.observation.NoOpObservationCollector

All Implemented Interfaces:

ObservationCollector

final class NoOpObservationCollector
extends Object
implements ObservationCollector

Nested Class Summary

Nested classes/interfaces inherited from interface ObservationCollector

ObservationCollector.BasicGetCall, ObservationCollector.ConnectionInfo, ObservationCollector.PublishCall

Field Summary

Fields inherited from interface ObservationCollector

NO_OP

Constructor Summary

Constructors

Constructor	Description
NoOpObservationCollector()

Method Summary

Modifier and Type	Method	Description
Consumer	basicConsume(String queue, String consumerTag, Consumer consumer)	Decorate consumer registration.
GetResponse	basicGet(ObservationCollector.BasicGetCall call, 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 Object

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

Constructor Details

NoOpObservationCollector

NoOpObservationCollector()

Method Details

publish

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

Description copied from interface: ObservationCollector

Decorate message publishing.

Implementations are expected to call

invalid reference

PublishCall#publish(PublishCall, AMQP.Basic.Publish, AMQP.BasicProperties, byte[], ConnectionInfo)

to make sure the message is actually sent.

Specified by:

publish in interface ObservationCollector

Parameters:

call -

publish -

properties -

body -

connectionInfo -

Throws:

IOException

basicConsume

public Consumer basicConsume(String queue,
 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

Parameters:

queue -

consumerTag -

consumer -

Returns:

basicGet

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

Description copied from interface: ObservationCollector

Decorate message polling with basic.get.

Implementations are expected to

invalid reference

BasicGetCall#basicGet(BasicGetCall, String)

and return the same result.

Specified by:

basicGet in interface ObservationCollector

Parameters:

call -

queue -

Returns: