mockforge-amqp 0.3.28

AMQP protocol support for MockForge
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

/// Consumer for AMQP queues
#[derive(Debug)]
pub struct Consumer {
    pub tag: String,
    pub queue: String,
    pub no_ack: bool,
    pub prefetch_count: u16,
}

impl Consumer {
    pub fn new(tag: String, queue: String, no_ack: bool, prefetch_count: u16) -> Self {
        Self {
            tag,
            queue,
            no_ack,
            prefetch_count,
        }
    }
}