Rejected data objects
Common Measurement Object that provides common methods for collecting and exposes measurement data that is submitted in
rejected.consumer.Consumerfor submission to statsd or influxdb.
Counters that are affected by
List of duration values (float or int)
Tag key/value pairs for use with InfluxDB
Numeric values such as integers, gauges, and such.
New in version 3.13.0.
Add a duration for the specified key
New in version 3.19.0.
Decrement a counter.
Increment a counter.
Set a tag. This is only used for InfluxDB measurements.
Set a value.
Message(connection, channel, method, properties, body)¶
Class for containing all the attributes about a message object creating a flatter, move convenient way to access the data while supporting the legacy methods that were previously in place in rejected < 2.0
The AMQP message body
The name of the connection that the message was received on.
The channel that the message was was received on.
The consumer tag registered with RabbitMQ that identifies which consumer registered to receive this message.
The delivery tag that represents the deliver of this message with RabbitMQ.
The exchange the message was published to
pika.spec.Basic.Returnobject that represents how the message was received by rejected.
BasicPropertiesobject that represents the message’s AMQP properties.
A flag that indicates the message was previously delivered by RabbitMQ.
The routing key that was used to deliver the message.
A class that represents all of the field attributes of AMQP’s
Creating application id
MIME content type
MIME content encoding
Application correlation identifier
Non-persistent (1) or persistent (2)
Message expiration specification
Message header field table
Application message identifier
Message priority, 0 to 9
Address to reply to
Message type name
Creating user id