Struct TopicMatcher 

pub struct TopicMatcher<'a> {
    pub mid: i32,
    /* private fields */
}

Matching subscription topics. Returned from Mosquitto::subscribe.

Fields

mid: i32

the subscription id.

Implementations

impl<'a> TopicMatcher<'a>

pub fn matches(&self, msg: &MosqMessage) -> bool

true if a message matches a subscription topic

Examples found in repository

examples/subscribe-and-listen.rs (line 17)

fn main() {
    let m = Mosquitto::new("test");

    m.will_set("test/will",b"finished!",0,false).expect("can't set will");

    m.connect("localhost",1883).expect("can't connect");
    let bonzo = m.subscribe("bonzo/#",0).expect("can't subscribe to bonzo");
    let frodo = m.subscribe("frodo/#",0).expect("can't subscribe to frodo");

    // not interested in any retained messages!
    let mut mc = m.callbacks(());
    mc.on_message(|_,msg| {
        if ! msg.retained() {
            if bonzo.matches(&msg) {
                println!("bonzo {:?}",msg);
            } else
            if frodo.matches(&msg) {
                println!("frodo {:?}",msg);
                m.disconnect().unwrap();
            }
        }
    });

    m.loop_forever(200).expect("broken loop");
}

pub fn receive_many(&self, millis: i32) -> Result<Vec<MosqMessage>>

receive and return messages matching this topic, until timeout

Examples found in repository

examples/self-publish-receive-many.rs (line 20)

fn run() -> mosq::Result<()> {
    let m = Mosquitto::new("test");

    m.connect_wait("localhost",1883,300)?;
    let bilbo = m.subscribe("bilbo/#",1)?;

    let mt = m.clone();
    thread::spawn(move || {
        for i in 0..5 {
            let topic = format!("bilbo/{}",10*(i+1));
            let data = format!("hello #{}",i);
            mt.publish(&topic,data.as_bytes(), 1, false).unwrap();
        }
    });

    let msgs = bilbo.receive_many(300)?;
    for msg in msgs {
        println!("topic {} text '{}'",msg.topic(),msg.text());
    }
    Ok(())
}

pub fn receive_one(&self, millis: i32) -> Result<MosqMessage>

receive and return exactly one message matching this topic