File tree Expand file tree Collapse file tree 1 file changed +6
-14
lines changed Expand file tree Collapse file tree 1 file changed +6
-14
lines changed Original file line number Diff line number Diff line change 11<h1 align =" center " >RabbitMQ Stream Rust</h1 >
2-
3- <div align =" center " >
4- <strong>
5- A Work in progress Rust Client for RabbitMQ Stream
6- </strong>
7- </div >
8-
92<br />
10-
113<div align =" center " >
124 <strong >
135 A Work in progress Rust Client for RabbitMQ Stream
@@ -101,9 +93,9 @@ use rabbitmq_stream_client::{Environment, types::Message};
10193let environment = Environment::builder().build().await?;
10294let producer = environment.producer().name("myproducer").build("mystream").await?;
10395for i in 0..10 {
104- producer
105- .send(Message::builder().body(format!("message{}", i)).build())
106- .await?;
96+ producer
97+ .send(Message::builder().body(format!("message{}", i)).build())
98+ .await?;
10799}
108100producer.close().await?;
109101```
@@ -119,9 +111,9 @@ let environment = Environment::builder().build().await?;
119111let mut consumer = environment.consumer().build("mystream").await?;
120112let handle = consumer.handle();
121113task::spawn(async move {
122- while let Some(delivery) = consumer.next().await {
123- println!("Got message {:?}",delivery);
124- }
114+ while let Some(delivery) = consumer.next().await {
115+ println!("Got message {:?}",delivery);
116+ }
125117});
126118// wait 10 second and then close the consumer
127119sleep(Duration::from_secs(10)).await;
You can’t perform that action at this time.
0 commit comments