Package com.rabbitmq.client.observation
Class NoOpObservationCollector
java.lang.Object
com.rabbitmq.client.observation.NoOpObservationCollector
- All Implemented Interfaces:
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 -
Method Summary
Modifier and TypeMethodDescriptionbasicConsume
(String queue, String consumerTag, Consumer consumer) Decorate consumer registration.basicGet
(ObservationCollector.BasicGetCall call, 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.
-
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
ObservationCollector.publish(PublishCall, AMQP.Basic.Publish, AMQP.BasicProperties, byte[], ConnectionInfo)
to make sure the message is actually sent.- Specified by:
publish
in interfaceObservationCollector
- Parameters:
call
-publish
-properties
-body
-connectionInfo
-- Throws:
IOException
-
basicConsume
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
- Parameters:
queue
-consumerTag
-consumer
-- Returns:
-
basicGet
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
- Parameters:
call
-queue
-- Returns:
-