Crate amqp_lapin_helper
source ·Modules
- Helpers to handle AMQP flags.
- Generation utilities for the various AMQP types.
- Parsing utilities for the various AMQP types.
Structs
- AMQP Client
- An array of bytes (RabbitMQ specific)
- Main entry point for most AMQP operations.
- A TCP connection to the AMQP server.
- A Decimal value composed of a scale and a value
- A received AMQP message.
- An array of AMQPValue
- A Map<String, AMQPValue>
- Continuously consumes message from a Queue.
- A String
- needs to be a MPSC queue, in order there’s a disconnection, messages still could be added to the queue but needs to wait to be connected to AMQP in order to process the queue and send the msg on the broker maybe have a “PublisherQueue”
- This will send a copy of the receiver to receive a signal that says the consumer & publisher are ready so we could start the software and making sure we’ve haven’t missed any messages.
- A String (deprecated)
Enums
- Enumeration referencing all the available AMQP types
- Enumeration referencing the possible AMQP values depending on the types
Traits
- Plug listeners to the broker.
- Tag an object as Publishable
Type Aliases
- Type alias for AMQP BasicProperties
- A bool
- A Channel identifier
- The size of a chunk of a delivery’s payload
- The number of consumers
- A delivery tag
- A f64
- A f32
- the size of an AMQP frame
- The maximum heartbeat interval
- An identifier (class id or method id)
- An i32
- An i64
- A u64
- A u32
- The number of messages
- The size of a delivery’s payload
- A reply code (for closing channels and connections)
- An i16
- An i8
- A u8
- A u16
- A timestamp (u64)
- No value