Struct Producer 

pub struct Producer { /* private fields */ }

Implementations

impl Producer

pub fn connect( addr: &SocketAddr, handle: &Handle, config: Config, ) -> Box<dyn Future<Item = Producer, Error = Error>>

Establish a connection and send protocol version.

Examples found in repository

examples/pub.rs (line 17)

fn main() {
    let mut core = Core::new().unwrap();
    let handle = core.handle();
     
    let addr = "127.0.0.1:4150".parse().unwrap();

    let res = Producer::connect(&addr, &handle, Config::default())
       .and_then(|conn| {
           conn.publish("some_topic".into(), "some_message".into())
           .and_then(move |response| {
              println!("Response: {:?}", response);
              Ok(())
           })
       });
    core.run(res).unwrap();
}

examples/mpub.rs (line 21)

fn main() {
    let mut core = Core::new().unwrap();
    let handle = core.handle();

    let addr = "127.0.0.1:4150".parse().unwrap();

    let mut messages: Vec<String> = Vec::new();
    messages.push("First message".into());
    messages.push("Second message".into());

    let res = Producer::connect(&addr, &handle, Config::default())
       .and_then(|conn| {
           conn.mpublish("some_topic".into(), messages)
           .and_then(move |response| {
              println!("Response: {:?}", response);
              Ok(())
           })
       });
    core.run(res).unwrap();
}

pub fn publish( &self, topic: String, message: String, ) -> Box<dyn Future<Item = Message<String, Body<Message, Error>>, Error = Error>>

Examples found in repository

examples/pub.rs (line 19)

fn main() {
    let mut core = Core::new().unwrap();
    let handle = core.handle();
     
    let addr = "127.0.0.1:4150".parse().unwrap();

    let res = Producer::connect(&addr, &handle, Config::default())
       .and_then(|conn| {
           conn.publish("some_topic".into(), "some_message".into())
           .and_then(move |response| {
              println!("Response: {:?}", response);
              Ok(())
           })
       });
    core.run(res).unwrap();
}

pub fn mpublish( &self, topic: String, messages: Vec<String>, ) -> Box<dyn Future<Item = Message<String, Body<Message, Error>>, Error = Error>>

Examples found in repository

examples/mpub.rs (line 23)

fn main() {
    let mut core = Core::new().unwrap();
    let handle = core.handle();

    let addr = "127.0.0.1:4150".parse().unwrap();

    let mut messages: Vec<String> = Vec::new();
    messages.push("First message".into());
    messages.push("Second message".into());

    let res = Producer::connect(&addr, &handle, Config::default())
       .and_then(|conn| {
           conn.mpublish("some_topic".into(), messages)
           .and_then(move |response| {
              println!("Response: {:?}", response);
              Ok(())
           })
       });
    core.run(res).unwrap();
}

pub fn dpublish( &self, topic: String, message: String, defer_time: i64, ) -> Box<dyn Future<Item = Message<String, Body<Message, Error>>, Error = Error>>