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
All Methods Instance Methods Concrete Methods 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 withbasic.get
.void
publish(ObservationCollector.PublishCall call, AMQP.Basic.Publish publish, AMQP.BasicProperties properties, byte[] body, ObservationCollector.ConnectionInfo connectionInfo)
Decorate message publishing.
-
-
-
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 interfaceObservationCollector
- 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 originalConsumer
behavior should not be changed though.- Specified by:
basicConsume
in interfaceObservationCollector
- Returns:
-
basicGet
public GetResponse basicGet(ObservationCollector.BasicGetCall call, java.lang.String queue)
Description copied from interface:ObservationCollector
Decorate message polling withbasic.get
.Implementations are expected to
ObservationCollector.basicGet( BasicGetCall, String)
and return the same result.- Specified by:
basicGet
in interfaceObservationCollector
- Returns:
-
-