ruststream-lapin 0.5.2

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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

[package]
name = "ruststream-lapin"
description = "RabbitMQ / AMQP 0.9.1 broker implementation for the RustStream messaging framework, backed by lapin."
version.workspace = true
edition.workspace = true
rust-version.workspace = true
license.workspace = true
repository.workspace = true
authors.workspace = true
readme = "README.md"
keywords = ["rabbitmq", "amqp", "messaging", "broker", "faststream"]
categories = ["asynchronous", "network-programming"]

[lints]
workspace = true

[features]
default = []
# Ships the in-process test broker (`testing` module) plus the core harness wiring it needs.
testing = ["ruststream/conformance", "ruststream/testing"]
# TLS backends, mapped 1:1 onto lapin's cargo features.
tls-native-tls = ["lapin/native-tls"]
tls-rustls = ["lapin/rustls"]
tls-rustls-ring = ["lapin/rustls", "lapin/rustls--ring"]
# Typed support for the consistent-hash exchange plugin (server-side hash fan-out). The typed
# constructor lowers to the plugin's exchange type, so the plugin must be enabled on the broker.
plugin-consistent-hash = []
# Delayed-message-exchange plugin backend for `RabbitQueue::delay` (an alternative to the stock
# TTL waiting queue). Needs the plugin enabled on the broker.
plugin-dme = []

[dependencies]
ruststream = { workspace = true }
lapin = { workspace = true }
bytes = { workspace = true }
futures = { workspace = true }
thiserror = { workspace = true }
tokio = { workspace = true }
tracing = { workspace = true }

[dev-dependencies]
ruststream = { workspace = true, features = ["conformance", "testing", "macros", "json"] }
serde = { version = "1", features = ["derive"] }
tokio = { workspace = true }

[package.metadata.docs.rs]
all-features = true

# The lapin_* examples are the docs-site snippet sources; keep them runnable and snippet-checked.
[[example]]
name = "lapin_quickstart"

[[example]]
name = "lapin_topology"

[[example]]
name = "lapin_transactions"

[[example]]
name = "lapin_rpc_server"

[[example]]
name = "lapin_rpc_client"

[[example]]
name = "lapin_keyed_lanes"

[[example]]
name = "lapin_testing"
required-features = ["testing"]

[[example]]
name = "lapin_consistent_hash"
required-features = ["plugin-consistent-hash"]