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 recovery;
22mod reply;
23mod requester;
24mod subscriber;
25mod topology;
26mod transaction;
27
28pub mod context;
29pub mod prelude;
30
31pub use broker::{ClosedLapinBroker, ConnectedLapinBroker, LapinBroker};
32pub use delay::Delay;
33pub use error::AmqpError;
34pub use exchange::RabbitExchange;
35pub use message::{LapinMessage, PARTITION_KEY_HEADER};
36pub use publish_policy::{ConfirmsPublish, LapinPublish, LapinPublishPolicy, ServerTxPublish};
37pub use publish_step::{
38    EXPIRATION_HEADER, LapinPublishOptions, LapinPublishSteps, PRIORITY_HEADER,
39};
40pub use publisher::{ConfirmsPublisher, LapinPublisher, ServerTxPublisher};
41pub use queue::{QueueDescriptor, QueueSpec, RabbitQueue, RabbitQuorumQueue};
42pub use reply::DirectReplyTo;
43pub use requester::{LapinRequest, LapinRequester};
44pub use subscriber::LapinSubscriber;
45pub use transaction::ConfirmsTransaction;
46
47// Raw declaration-argument passthrough (`RabbitQueue::argument` / `arguments`).
48pub use lapin::types::{AMQPValue, FieldTable};