fix: readme futures crate - missing args in basic_publish(..)
@@ -28,7 +28,7 @@ use futures::future::Future;
use tokio_core::reactor::Core;
use tokio_core::net::TcpStream;
use lapin::client::ConnectionOptions;
-use lapin::channel::{BasicPublishOptions,QueueDeclareOptions};
+use lapin::channel::{BasicPublishOptions,QueueDeclareOptions, BasicProperties};
fn main() {
@@ -59,7 +59,8 @@ fn main() {
channel.queue_declare("hello", &QueueDeclareOptions::default(), FieldTable::new()).and_then(move |_| {
info!("channel {} declared queue {}", id, "hello");
- channel.basic_publish("hello", b"hello from tokio", &BasicPublishOptions::default())
+ channel.basic_publish("hello", b"hello from tokio", &BasicPublishOptions::default(),
+ BasicProperties::default())
})
})
).unwrap();
