Struct amqpr::unsync::GlobalChannel
[−]
[src]
pub struct GlobalChannel { /* fields omitted */ }
Methods
impl GlobalChannel[src]
fn open_channel(
self,
channel_id: u16
) -> Box<Future<Item = (GlobalChannel, LocalChannel), Error = Rc<Error>>>[src]
self,
channel_id: u16
) -> Box<Future<Item = (GlobalChannel, LocalChannel), Error = Rc<Error>>>
Open new local channel.
Returned future's item is (GloblChannel, LocalChannel).
fn heartbeat(&self, interval: Duration, handle: &Handle) -> Receiver<Rc<Error>>[src]
Start sending heartbeat frame to AMQP server.