Skip to main content

ruststream_lapin/
lib.rs

1#![doc = include_str!("README.md")]
2#![forbid(unsafe_code)]
3
4#[cfg(feature = "asyncapi")]
5mod bindings;
6mod broker;
7mod channel;
8mod convert;
9mod delay;
10mod error;
11mod exchange;
12#[cfg(feature = "testing")]
13mod in_process;
14#[cfg(feature = "testing")]
15mod live_routes;
16mod message;
17mod publish_policy;
18mod publish_step;
19mod publisher;
20mod queue;
21mod reply;
22mod requester;
23mod subscriber;
24mod topology;
25mod transaction;
26
27pub mod context;
28pub mod prelude;
29
30pub use broker::{ClosedLapinBroker, ConnectedLapinBroker, LapinBroker};
31pub use delay::Delay;
32pub use error::AmqpError;
33pub use exchange::RabbitExchange;
34pub use message::{LapinMessage, PARTITION_KEY_HEADER};
35pub use publish_policy::{ConfirmsPublish, LapinPublish, LapinPublishPolicy, ServerTxPublish};
36pub use publish_step::{
37    EXPIRATION_HEADER, LapinPublishOptions, LapinPublishSteps, PRIORITY_HEADER,
38};
39pub use publisher::{ConfirmsPublisher, LapinPublisher, ServerTxPublisher};
40pub use queue::{QueueDescriptor, QueueSpec, RabbitQueue, RabbitQuorumQueue};
41pub use reply::DirectReplyTo;
42pub use requester::{LapinRequest, LapinRequester};
43pub use subscriber::LapinSubscriber;
44pub use transaction::ConfirmsTransaction;
45
46// Raw declaration-argument passthrough (`RabbitQueue::argument` / `arguments`).
47pub use lapin::types::{AMQPValue, FieldTable};