1extern crate futures;
2extern crate tokio_core;
3extern crate nsqueue;
4
5use futures::Future;
6use tokio_core::reactor::Core;
7
8use nsqueue::config::*;
9use nsqueue::producer::*;
10
11fn main() {
12 let mut core = Core::new().unwrap();
13 let handle = core.handle();
14
15 let addr = "127.0.0.1:4150".parse().unwrap();
16
17 let res = Producer::connect(&addr, &handle, Config::default())
18 .and_then(|conn| {
19 conn.publish("some_topic".into(), "some_message".into())
20 .and_then(move |response| {
21 println!("Response: {:?}", response);
22 Ok(())
23 })
24 });
25 core.run(res).unwrap();
26}