rmq-rpc

Early release, not stable enough!

Client\server for RPC via RabbitMQ

Please look at examples directory for complete examples.

Server example

```rust use rmq_rpc::RmqRpcServer; use std::io::Error;

const URL: &str = "amqp://127.0.0.1:5672"; const QUEUE_NAME: &str = "examples";

async fn handler(data: Vec) -> Result, Error> { let mut res = data.to_owned(); res.reverse(); Ok(res) }

[tokio::main]

async fn main() { let server = RmqRpcServer::connect(URL).await.unwrap(); server.declarequeue(QUEUENAME).await.unwrap();

server.drain(QUEUE_NAME, handler).await.unwrap();

} ```

Client example

```rust use rmq_rpc::RmqRpcClient; use std::env;

const URL: &str = "amqp://127.0.0.1:5672"; const QUEUE_NAME: &str = "examples";

[tokio::main]

async fn main() { let msg = match env::args().skip(1).next().unwrap();

let client = RmqRpcClient::connect(URL).await.unwrap();
client.declare_queue(QUEUE_NAME).await.unwrap();

let _ = client
    .send_message(QUEUE_NAME, msg.as_bytes().to_vec())
    .await
    .unwrap();

} ```