foxtive 0.25.6

Foxtive Framework
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

use crate::prelude::AppResult;
use lapin::message::Delivery;
use lapin::options::{BasicAckOptions, BasicNackOptions};
use lapin::types::ShortString;

pub struct Message {
    delivery: Delivery,
}

impl Message {
    pub fn new(delivery: Delivery) -> Self {
        Self { delivery }
    }

    pub fn delivery(&self) -> &Delivery {
        &self.delivery
    }

    pub fn data(&self) -> &Vec<u8> {
        &self.delivery.data
    }

    pub fn str(&self) -> AppResult<&str> {
        Ok(std::str::from_utf8(&self.delivery.data)?)
    }

    pub fn routing_key(&self) -> &ShortString {
        &self.delivery.routing_key
    }

    pub fn deserialize<T>(&self) -> AppResult<T>
    where
        T: serde::de::DeserializeOwned,
    {
        Ok(serde_json::from_slice(&self.delivery.data)?)
    }

    pub async fn ack(&self) -> AppResult<()> {
        self.ack_opt(BasicAckOptions::default()).await?;
        Ok(())
    }

    pub async fn nack(&self) -> AppResult<()> {
        self.nack_opt(BasicNackOptions::default()).await
    }

    pub async fn ack_opt(&self, opt: BasicAckOptions) -> AppResult<()> {
        self.delivery.acker.ack(opt).await?;
        Ok(())
    }

    pub async fn nack_opt(&self, opt: BasicNackOptions) -> AppResult<()> {
        self.delivery.acker.nack(opt).await?;
        Ok(())
    }
}