Struct Mq

pub struct Mq { /* private fields */ }

Implementations

impl Mq

pub fn new() -> Mq

pub fn set_task(&mut self, task: Task)

pub fn push( &mut self, message: Arc<StompMessage>, headers: Vec<Header>, ) -> usize

pub fn next(&mut self) -> Option<SessionMessage>

pops a message and transfers ownership

pub fn len(&self) -> usize

pub fn close(&mut self)

pub fn is_closed(&self) -> bool

pub fn drain(&mut self) -> Result<(), usize>

Tell the MQ to stop accepting new messages and carry on writing any existing ones. When there are none left shutdown

pub fn notify(&self)

pub fn poll(&self) -> Result<Async<()>, ()>