rskit_messaging_rabbitmq/
lib.rs

1//! `RabbitMQ` adapter for `rskit-messaging`.
2//!
3//! The adapter uses AMQP queues named by message topic by default. Registration is explicit
4//! and side-effect free; network connections are opened lazily.
5
6#![warn(missing_docs)]
7
8mod config;
9mod connection;
10mod consumer;
11mod error;
12mod producer;
13mod register;
14#[cfg(test)]
15mod tests;
16
17pub use config::RabbitMqConfig as Config;
18pub use register::register;
19
20#[cfg(test)]
21pub(crate) use config::{queue_for, validate_name};
22#[cfg(test)]
23pub(crate) use consumer::{RabbitMqConsumer, shutdown_consumer_tasks, spawn_forwarding_task};
24#[cfg(test)]
25pub(crate) use error::{
26    channel_close_failed, channel_failed, connect_failed, connect_timed_out,
27    connection_close_failed, consume_failed, publish_confirm_failed, publish_failed,
28    qos_configuration_failed, queue_declare_failed,
29};
30#[cfg(test)]
31pub(crate) use producer::RabbitMqProducer;
32#[cfg(test)]
33pub(crate) use register::RabbitMqFactory;
rskit_messaging_rabbitmq/lib.rs

rskit_messaging_rabbitmq/
lib.rs
