Struct libzmq::Msg

pub struct Msg { /* fields omitted */ }

A handle to a message owned by ØMQ.

A ØMQ message is a discrete unit of data passed between applications or components of the same application. ØMQ messages have no internal structure and from the point of view of ØMQ itself they are considered to be opaque binary data.

Implementations

impl Msg

pub fn new() -> Self

Create an empty Msg.

See zmq_msg_init.

use libzmq::Msg;

let msg = Msg::new();

assert!(msg.is_empty());

pub fn with_size(size: usize) -> Self

Create a Msg preallocated with len zeroed bytes.

See zmq_msg_init_size.

use libzmq::Msg;

let size = 420;
let msg = Msg::with_size(size);

assert_eq!(msg.len(), size);

pub fn len(&self) -> usize

Returns the message content size in bytes.

See zmq_msg_size.

pub fn is_empty(&self) -> bool

Returns true if the message content has size zero.

pub fn to_str(&self) -> Result<&str, Utf8Error>

Return the message content as a str slice if it is valid UTF-8.

use libzmq::Msg;

let text = "blzit";
let msg = Msg::from(text);

assert_eq!(msg.to_str()?, text);

pub fn as_bytes(&self) -> &[u8]

Return the message content as a byte slice.

use libzmq::Msg;

let bytes: &[u8] = b"blzit";
let msg = Msg::from(bytes);

assert_eq!(msg.as_bytes(), bytes);

pub fn as_bytes_mut(&mut self) -> &mut [u8]

Return the message content as a mutable byte slice.

pub fn routing_id(&self) -> Option<RoutingId>

Get routing ID property on the message.

See zmq_msg_routing_id.

pub fn set_routing_id(&mut self, routing_id: RoutingId)

Set routing ID property on the message.

Usage Contract

• Cannot be zero

Returned Error Variants

• InvalidInput (if contract is not followed)

See zmq_msg_set_routing_id.

pub fn group(&self) -> Option<&GroupSlice>

The group property on the message.

pub fn set_group<G>(&mut self, group: G) where
    G: AsRef<GroupSlice>, 

Set the group property on the message.

use libzmq::{prelude::TryInto, Msg, Group};

let a: Group = "A".try_into()?;

let mut msg: Msg = "some msg".into();
msg.set_group(&a);
assert_eq!(a, msg.group().unwrap());

Usage Contract

• Cannot hold more than 15 characters.

Returned Error Variants

• InvalidInput (if contract is not followed)

Trait Implementations

impl Clone for Msg

fn clone(&self) -> Self

Copy the content of the message into another message.

See zmq_msg_copy.

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

Performs copy-assignment from source.

impl Debug for Msg

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

Formats the value using the given formatter.

impl Default for Msg

fn default() -> Self

Initialises an empty ØMQ message.

See zmq_msg_init.

impl Drop for Msg

fn drop(&mut self)

Releases the ØMQ message.

See zmq_msg_close.

impl Eq for Msg

impl<'a, '_> From<&'_ [u8]> for Msg

fn from(slice: &[u8]) -> Self

Converts a byte slice into a Msg by copying.

impl<'a, T> From<&'a T> for Msg where
    T: Into<Msg> + Clone, 

fn from(v: &'a T) -> Self

Performs the conversion.

impl<'a> From<&'a str> for Msg

fn from(text: &str) -> Self

Converts a str slice into a Msg by copying.

impl From<[u8; 0]> for Msg

fn from(array: [u8; 0]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 1]> for Msg

fn from(array: [u8; 1]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 10]> for Msg

fn from(array: [u8; 10]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 11]> for Msg

fn from(array: [u8; 11]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 12]> for Msg

fn from(array: [u8; 12]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 13]> for Msg

fn from(array: [u8; 13]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 14]> for Msg

fn from(array: [u8; 14]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 15]> for Msg

fn from(array: [u8; 15]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 16]> for Msg

fn from(array: [u8; 16]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 17]> for Msg

fn from(array: [u8; 17]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 18]> for Msg

fn from(array: [u8; 18]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 19]> for Msg

fn from(array: [u8; 19]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 2]> for Msg

fn from(array: [u8; 2]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 20]> for Msg

fn from(array: [u8; 20]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 21]> for Msg

fn from(array: [u8; 21]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 22]> for Msg

fn from(array: [u8; 22]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 23]> for Msg

fn from(array: [u8; 23]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 24]> for Msg

fn from(array: [u8; 24]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 25]> for Msg

fn from(array: [u8; 25]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 26]> for Msg

fn from(array: [u8; 26]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 27]> for Msg

fn from(array: [u8; 27]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 28]> for Msg

fn from(array: [u8; 28]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 29]> for Msg

fn from(array: [u8; 29]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 3]> for Msg

fn from(array: [u8; 3]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 30]> for Msg

fn from(array: [u8; 30]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 31]> for Msg

fn from(array: [u8; 31]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 32]> for Msg

fn from(array: [u8; 32]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 4]> for Msg

fn from(array: [u8; 4]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 5]> for Msg

fn from(array: [u8; 5]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 6]> for Msg

fn from(array: [u8; 6]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 7]> for Msg

fn from(array: [u8; 7]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 8]> for Msg

fn from(array: [u8; 8]) -> Self

Converts an array into a Msg without copying.

impl From<[u8; 9]> for Msg

fn from(array: [u8; 9]) -> Self

Converts an array into a Msg without copying.

impl From<Box<[u8]>> for Msg

fn from(data: Box<[u8]>) -> Msg

Converts of box of bytes into a Msg without copying.

impl From<String> for Msg

fn from(text: String) -> Self

Converts a String into a Msg by without copying.

impl From<Vec<u8>> for Msg

fn from(bytes: Vec<u8>) -> Self

Converts a byte vector into a Msg without copying.

impl PartialEq<Msg> for Msg

fn eq(&self, other: &Self) -> bool

Compares the two underlying raw C pointers.

#[must_use]fn ne(&self, other: &Rhs) -> bool

This method tests for !=.