Struct lapin_async::channel::Channel

pub struct Channel {
    pub id: u16,
    pub state: ChannelState,
    pub frame_queue: VecDeque<AMQPFrame>,
    pub send_flow: bool,
    pub receive_flow: bool,
    pub queues: HashMap<String, Queue>,
    pub prefetch_size: u32,
    pub prefetch_count: u16,
    pub awaiting: VecDeque<Answer>,
    pub confirm: bool,
    pub message_count: u64,
    pub acked: HashSet<u64>,
    pub nacked: HashSet<u64>,
    pub unacked: HashSet<u64>,
}

Fields

id: u16

state: ChannelState

frame_queue: VecDeque<AMQPFrame>

send_flow: bool

receive_flow: bool

queues: HashMap<String, Queue>

prefetch_size: u32

prefetch_count: u16

awaiting: VecDeque<Answer>

confirm: bool

message_count: u64

acked: HashSet<u64>

nacked: HashSet<u64>

unacked: HashSet<u64>

Methods

impl Channel

pub fn new(channel_id: u16) -> Channel

pub fn global() -> Channel

pub fn received_method(&mut self, m: AMQPClass)

pub fn is_connected(&self) -> bool

Trait Implementations

impl Debug for Channel

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.