Struct Msg

pub struct Msg {
    pub timestamp: i64,
    pub attemps: u16,
    pub id: String,
    pub body: Vec<u8>,
}

Message sent by nsqd

Examples

struct Consumer(Addr<Connection>);

impl Actor for Consumer {
    type Context = Context<Self>;
    fn handle(&mut self, ctx: &mut Self::Context) {
        self.subscribe::<Msg>(ctx, self.0.clone());
    }
}

fn Handler<Msg> for Consumer {
    type Result = ();
    fn handle(&mut self, msg: Msg, _: &mut Self::Context) {
        println!("timestamp: {}", msg.timestamp);
        println!("attemps: {}", msg.attemps);
        println!("id: {}", msg.id);
        println!("data: {}", msg.body);
        println!("msg debug: {:?}", msg);
    }
}

Fields

timestamp: i64

Timestamp of the message

attemps: u16

Number of attemps reader tried to process the message

id: String

Id of the message

body: Vec<u8>

Data sent by nsqd

Trait Implementations

impl Clone for Msg

fn clone(&self) -> Msg

Returns a duplicate of the value.

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

Returns the “default value” for a type.

impl Message for Msg

type Result = ()

The type of value that this message will resolved with if it is successful.