2 releases
0.1.2 | May 23, 2021 |
---|---|
0.1.1 | May 22, 2021 |
0.1.0 |
|
#48 in #rabbitmq
21KB
503 lines
rmq-rpc
Early release, not stable enough!
Client\server for RPC via RabbitMQ
Please look at examples
directory for complete examples.
Server example
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<u8>) -> Result<Vec<u8>, Error> {
let mut res = data.to_owned();
res.reverse();
Ok(res)
}
#[tokio::main]
async fn main() {
let server = RmqRpcServer::connect(URL).await.unwrap();
server.declare_queue(QUEUE_NAME).await.unwrap();
server.drain(QUEUE_NAME, handler).await.unwrap();
}
Client example
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();
}
Dependencies
~8–18MB
~236K SLoC