🐰 kanin

A framework for AMQP built on top of lapin that makes it easy to create RPC microservices in Rust 🦀, using Protobuf.

Usage

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.

Testing

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.