Crate coreon_amqp 

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.

Structs

AmqpComponent

AmqpConsumer

AmqpEndpoint

AmqpProducer