ollie 0.2.5

This library serves as an abstraction layer on top of lapin, making it more intuitive and aligned with the structure of traditional HTTP API routing. By bridging the gap between message-based RabbitMQ operations and familiar API concepts, it simplifies the process of defining, managing, and handling message routes. The goal is to streamline message routing, making it easier for developers to create robust and scalable systems while leveraging the full capabilities of RabbitMQ.
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use std::time::Duration;

use serde::{Deserialize, Serialize};


#[derive(Debug,Serialize,Deserialize)]
pub struct RabbitResult{
    pub logging_level: LoggingLevel,
    pub billing_type: BillingType,
    pub task_result: TaskResult,
}

#[derive(Debug,Serialize,Deserialize)]
pub struct TaskResult {
    pub task_id: String,
    pub engine_metadata: EngineMetadata,
    pub data: serde_json::Value,
}

#[derive(Debug,Serialize,Deserialize)]
pub struct EngineMetadata{
    pub engine_id: String,
    pub time_taken: Duration,
}

#[derive(Debug,Serialize,Deserialize)]
pub enum LoggingLevel {
    Unlogged,
    Debug,
    Info,
    Warning,
    Error,
}

impl ToString for LoggingLevel {
    fn to_string(&self) -> String {
        match self {
            LoggingLevel::Unlogged => "Unlogged".to_string(),
            LoggingLevel::Debug => "Debug".to_string(),
            LoggingLevel::Info => "Info".to_string(),
            LoggingLevel::Warning => "Warning".to_string(),
            LoggingLevel::Error => "Error".to_string(),
        }
    }
}

#[derive(Debug,Serialize,Deserialize)]
pub enum BillingType {
    Prepaid,
    Postpaid,
    NotBilled,
}

impl ToString for BillingType {
    fn to_string(&self) -> String {
        match self {
            BillingType::Prepaid => "Prepaid".to_string(),
            BillingType::Postpaid => "Postpaid".to_string(),
            BillingType::NotBilled => "NotBilled".to_string(),
        }
    }
}