coreon-amqp 0.1.0

amqp:* component for camel-rs (RabbitMQ via lapin).

Coverage
16.67%
1 out of 6 items documented0 out of 5 items with examples
Size
Source code size: 69.81 kB This is the summed size of all the files inside the crates.io package for this release.
Documentation size: 1.12 MB This is the summed size of all files generated by rustdoc for all configured targets
Ø build duration
this release: 1m 51s Average build duration of successful builds.
all releases: 1m 51s Average build duration of successful builds in releases after 2024-10-23.
Links
Repository
crates.io
Dependencies
Versions
- 0.1.0 (2026-04-22)
Owners

amqp:* — RabbitMQ / AMQP 0-9-1 producer and consumer via [lapin].

URI: amqp:<queue>?url=amqp://user:pass@host:5672/%2F&exchange=&prefetch=32

Producer: publishes exchange.in.body bytes to <exchange> with routing key = <queue>. If exchange is empty (default), publishes directly to the queue.
Consumer: declares the queue (idempotent), subscribes with the given prefetch, emits one Exchange per delivery. ACKs on pipeline success, NACKs (with requeue=false) on pipeline error.

Tests: marked #[ignore] unless AMQP_URL env var is set. docker run -p 5672:5672 rabbitmq:3.13-management then run AMQP_URL=amqp://guest:guest@localhost:5672/%2F cargo test -p camel-amqp -- --ignored.