A framework for AMQP built on top of lapin that makes it easy to create RPC microservices in Rust 🦀, using Protobuf.
Run cargo add kanin to add kanin to your Cargo.toml.
mod protobuf;
use kanin::{extract::Msg, App};
use protobuf::echo::{EchoRequest, EchoResponse};
async fn echo(Msg(request): Msg<EchoRequest>) -> EchoResponse {
EchoResponse::success(request.value)
}
#[tokio::main]
async fn main() -> kanin::Result<()> {
App::new(())
.handler("my_routing_key", echo)
.run("amqp_addr")
.await
}See the documentation for examples and more specific usage, or see the /minimal_example folder in this repo.
To run tests, install just and Docker (you need docker-compose).
Then, simply run just test, which will launch a RabbitMQ instance in a container that the tests will connect to.