[][src]Module amqp_manager::prelude

Re-exports

pub use crate::*;

Modules

r2d2

A generic connection pool.

Structs

AmqpSession

The struct used to manage amqp objects (exchanges, queues, consumers). Since it only contains a Channel instance, this struct is also thread-safe.

BasicAckOptions
BasicConsumeOptions
BasicPublishOptions
BasicReturnMessage
BindQueueToExchange
Bytes

A reference counted contiguous slice of memory.

CancelConsumers
ConnectionProperties
Consumer

Continuously consumes message from a Queue.

CreateConsumer
CreateExchange
CreateQueue
DeleteExchanges
DeleteQueues
Delivery

A received AMQP message.

ExchangeDeclareOptions
FieldTable

A Map<String, AMQPValue>

LapinConnectionManager

An r2d2::ManageConnection for lapin::Connections.

LongString

A String

PublishToExchange
PublishToQueue
Queue
QueueDeclareOptions
ShortString

A String (deprecated)

Enums

AMQPValue

Enumeration referencing the possible AMQP values depending on the types

Error

The type of error that can be returned in this crate.

ExchangeKind

Type Definitions

BasicProperties

Type alias for AMQP BasicProperties

DeliveryResult

Type wrapping the output of a consumer