ruststream-lapin 0.7.0

RabbitMQ / AMQP 0.9.1 broker implementation for the RustStream messaging framework, backed by lapin.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

#![doc = include_str!("README.md")]
#![forbid(unsafe_code)]

#[cfg(feature = "asyncapi")]
mod bindings;
mod broker;
mod channel;
mod convert;
mod delay;
mod error;
mod exchange;
#[cfg(feature = "testing")]
mod in_process;
mod message;
mod publish_policy;
mod publish_step;
mod publisher;
mod queue;
mod reply;
mod requester;
mod subscriber;
mod topology;
mod transaction;

pub mod context;
pub mod prelude;

pub use broker::{ClosedLapinBroker, ConnectedLapinBroker, LapinBroker};
pub use delay::Delay;
pub use error::AmqpError;
pub use exchange::RabbitExchange;
pub use message::{LapinMessage, PARTITION_KEY_HEADER};
pub use publish_policy::{ConfirmsPublish, LapinPublish, LapinPublishPolicy, ServerTxPublish};
pub use publish_step::{
    EXPIRATION_HEADER, LapinPublishOptions, LapinPublishSteps, PRIORITY_HEADER,
};
pub use publisher::{ConfirmsPublisher, LapinPublisher, ServerTxPublisher};
pub use queue::{QueueDescriptor, QueueSpec, RabbitQueue, RabbitQuorumQueue};
pub use reply::DirectReplyTo;
pub use requester::{LapinRequest, LapinRequester};
pub use subscriber::LapinSubscriber;
pub use transaction::ConfirmsTransaction;

// Raw declaration-argument passthrough (`RabbitQueue::argument` / `arguments`).
pub use lapin::types::{AMQPValue, FieldTable};