Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 42d1232

Browse files
committedMar 7, 2024
minor fix
1 parent 1c39dc7 commit 42d1232

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed
 

‎examples/rpc.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -213,12 +213,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
213213

214214
// Delete the queue
215215
// before starting the server
216-
open_channel()
217-
.await
218-
.map_err(|e| format!("Failed to open channel: {e}"))?
219-
.queue_delete("rpc_queue", QueueDeleteOptions::default())
220-
.await
221-
.map_err(|e| format!("Failed to delete queue rpc_queue: {e}"))?;
216+
// open_channel()
217+
// .await
218+
// .map_err(|e| format!("Failed to open channel: {e}"))?
219+
// .queue_delete("rpc_queue", QueueDeleteOptions::default())
220+
// .await
221+
// .map_err(|e| format!("Failed to delete queue rpc_queue: {e}"))?;
222222

223223
// In practice, the server and client could run
224224
// on distinct machines

0 commit comments

Comments
 (0)
Please sign in to comment.