amqp-manager 0.3.1

Lapin wrapper that encapsulates the use of connections/channels and provides some helpful methods
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
pub use bytes::Bytes;
pub use lapin;
pub use lapin::message::{BasicReturnMessage, Delivery, DeliveryResult};
pub use lapin::options::{BasicAckOptions, BasicConsumeOptions, BasicPublishOptions, ExchangeDeclareOptions, QueueDeclareOptions};
pub use lapin::types::{AMQPValue, FieldTable, LongString, ShortString};
pub use lapin::{BasicProperties, Channel, ConnectionProperties, Consumer, Error, ExchangeKind, Queue};
pub use mobc_lapin;
pub use mobc_lapin::mobc;
pub use mobc_lapin::RMQConnectionManager;

pub use crate::ops::*;
pub use crate::session::AmqpSession;
pub use crate::*;