Struct lapin_async::channel::Channel

pub struct Channel {
    pub id: u16,
    pub state: ChannelState,
    pub frame_queue: VecDeque<Frame>,
    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<Frame>

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: Class)

pub fn is_connected(&self) -> bool

Trait Implementations

impl Clone for Channel

fn clone(&self) -> Channel

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Channel

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

Formats the value using the given formatter.

impl PartialEq for Channel

fn eq(&self, __arg_0: &Channel) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, __arg_0: &Channel) -> bool

This method tests for !=.