amq-rpc 0.1.0

RabbitMQ RPC library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use serde::{Deserialize, Serialize};
use std::collections::HashMap;
use async_trait::async_trait;
use crate::error::RpcResult;

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Command {
    pub command: String,
    pub args: Vec<serde_json::Value>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct CommandResponse {
    pub success: bool,
    pub result: Option<serde_json::Value>,
    pub error: Option<String>,
}

#[async_trait]
pub trait CommandHandler: Send + Sync {
    async fn handle(&self, command: &str, args: Vec<serde_json::Value>) -> RpcResult<serde_json::Value>;
}

pub type CommandHandlers = HashMap<String, Box<dyn CommandHandler>>;

#[derive(Debug, Clone)]
pub struct RpcMessage {
    pub content: Vec<u8>,
    pub correlation_id: String,
    pub reply_queue: Option<String>,
    pub delivery_tag: u64,
}