Struct zkmq::ZkMQ

pub struct ZkMQ { /* fields omitted */ }

Implementations

impl ZkMQ

pub fn consume(&mut self, constraints: Option<Filters>) -> Result<ZkMQMessage>

Consume messages from the Queue

Optional Constraints can be provided as a Filters struct. Filters are basically a blacklist on message tags. If a message is tagged with scope, and you start a consumer without any filters, you will get all messages- tagged and untagged.

If you add a filter on scope, messages not matching the filter will be ignored. Messages missing the scope tag will be treated as if they fail to match the filter. So, if your FilterConditional is ALL and the scope tag is missing, it will fail. If is ANY, then it could still be valid.

pub fn produce<P: Into<Vec<u8>>>(&self, payload: P) -> Result<()>

Produce a message into the current queue.

Error is returned if the operation fails in any way.

pub fn product_adv(&self, message: ZkMQMessage) -> Result<()>

Produce a message a raw ZkMQMessage into the current queue

Trait Implementations

impl Clone for ZkMQ

fn clone(&self) -> ZkMQ

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ZkMQ

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

Formats the value using the given formatter.