rabbit_borough 0.1.2-alpha

Create a RabbitMQ consumer project with minimal effort, by bypassing templating, configuration and complicated resiliency logic
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

use lapin::Channel;
use lapin::options::BasicNackOptions;
use lapin::options::BasicAckOptions;
use lapin::types::LongLongUInt;

#[allow(dead_code)]
pub enum HandleMessageResult {
    Ack,
    NackNoRequeue,
    NackWithRequeue,
}

/// Consumer Acknowledgements
/// Sends Positive or Negative Acknowledgement
/// * Requeues if needed
pub async fn action_result(result: HandleMessageResult, channel: &Channel, tag: LongLongUInt) {
    match result {
        HandleMessageResult::Ack => {
            channel
                .basic_ack(tag, BasicAckOptions { multiple: false })
                .await
                .expect("basic_ack");
        }
        HandleMessageResult::NackNoRequeue => {
            channel
                .basic_nack(
                    tag,
                    BasicNackOptions {
                        multiple: false,
                        requeue: false,
                    },
                )
                .await
                .expect("basic_ack");
        }
        HandleMessageResult::NackWithRequeue => {
            channel
                .basic_nack(
                    tag,
                    BasicNackOptions {
                        multiple: false,
                        requeue: true,
                    },
                )
                .await
                .expect("basic_ack");
        }
    }
}