Modules§
- flags
- Helpers to handle AMQP flags.
- generation
- Generation utilities for the various AMQP types.
- message
- options
- parsing
- Parsing utilities for the various AMQP types.
- types
Structs§
- Access
Request Options - Basic
AckOptions - Basic
Cancel Options - Basic
Consume Options - Basic
Deliver Options - Basic
GetOk Options - Basic
GetOptions - Basic
Nack Options - Basic
Publish Options - Basic
QosOptions - Basic
Recover Async Options - Basic
Recover Options - Basic
Reject Options - Broker
- AMQP Client
- Byte
Array - An array of bytes (RabbitMQ specific)
- Channel
- Main entry point for most AMQP operations.
- Channel
Flow OkOptions - Channel
Flow Options - Confirm
Select Options - Connection
- A TCP connection to the AMQP server.
- Connection
Properties - Consumer
- Decimal
Value - A Decimal value composed of a scale and a value
- Delivery
- A received AMQP message.
- Exchange
Bind Options - Exchange
Declare Options - Exchange
Delete Options - Exchange
Unbind Options - Field
Array - An array of AMQPValue
- Field
Table - A Map<String, AMQPValue>
- Lapin
Consumer - Continuously consumes message from a Queue.
- Listener
- Long
String - A String
- Publisher
- 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”
- Publisher
Queue - Queue
- Queue
Bind Options - Queue
Declare Options - Queue
Delete Options - Queue
Message - Queue
Purge Options - Rate
Limiter - A token-bucket rate limiter.
- Ready
- 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.
- Short
String - A String (deprecated)
Enums§
- AMQP
Type - Enumeration referencing all the available AMQP types
- AMQP
Value - Enumeration referencing the possible AMQP values depending on the types
- Error
- Exchange
Kind
Traits§
- Broker
Listener - Plug listeners to the broker.
- Broker
Manager - Broker
Publish - Tag an object as Publishable
Type Aliases§
- Basic
Properties - Type alias for AMQP BasicProperties
- Boolean
- A bool
- Channel
Id - A Channel identifier
- Chunk
Size - The size of a chunk of a delivery’s payload
- Consume
Result - Consumer
Count - The number of consumers
- Delivery
Tag - A delivery tag
- Double
- A f64
- Float
- A f32
- Frame
Size - the size of an AMQP frame
- Heartbeat
- The maximum heartbeat interval
- Identifier
- An identifier (class id or method id)
- LongInt
- An i32
- Long
Long Int - An i64
- Long
LongU Int - A u64
- LongU
Int - A u32
- Message
Count - The number of messages
- Payload
Size - The size of a delivery’s payload
- Reply
Code - A reply code (for closing channels and connections)
- Requeue
- Result
- Short
Int - An i16
- Short
Short Int - An i8
- Short
ShortU Int - A u8
- ShortU
Int - A u16
- Timestamp
- A timestamp (u64)
- Void
- No value