rabbit_auto/
lib.rs

1//!
2//! Wrappers around RabbitMQ connection to indefinitely (after the first successful connection) consume,
3//! or publish without any errors. If the connection disconnects, the consumer and publisher will wait
4//! until the connection is established back again.
5//!
6// macro_rules! log_error {
7//     ($action: expr) => {
8//         if let Err(err) = $action {
9//             log::error!("{}: {}", stringify!($action), err);
10//         }
11//     };
12//     ($action: expr, $msg: expr) => {
13//         if let Err(err) = $action {
14//             log::error!("{}: {}", $msg, err);
15//         }
16//     };
17// }
18
19#[cfg(all(feature = "tokio_runtime", feature = "async_std_runtime"))]
20compile_error!("Tokio and Async-std are mutually exclusive");
21
22pub mod config;
23pub mod comms;
24pub mod consumer;
25
26pub mod exchanges;
27
28pub mod publisher;
29
30pub mod auto_ack;
31
32pub mod stream_builder;
33
34
35pub mod publish_properties;
rabbit_auto/lib.rs

rabbit_auto/
lib.rs
