Skip to content

Commit

Permalink
Merge pull request #114 from Dantsz/typo_fix
Browse files Browse the repository at this point in the history
examples: change rounting_key variable name to routing_key
  • Loading branch information
gftea authored Nov 5, 2023
2 parents 58d8425 + 1141656 commit de21bbe
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
6 changes: 3 additions & 3 deletions examples/src/basic_pub_sub.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,13 +52,13 @@ async fn main() {
.unwrap();

// bind the queue to exchange
let rounting_key = "amqprs.example";
let routing_key = "amqprs.example";
let exchange_name = "amq.topic";
channel
.queue_bind(QueueBindArguments::new(
&queue_name,
exchange_name,
rounting_key,
routing_key,
))
.await
.unwrap();
Expand All @@ -85,7 +85,7 @@ async fn main() {
.into_bytes();

// create arguments for basic_publish
let args = BasicPublishArguments::new(exchange_name, rounting_key);
let args = BasicPublishArguments::new(exchange_name, routing_key);

channel
.basic_publish(BasicProperties::default(), content, args)
Expand Down
4 changes: 2 additions & 2 deletions examples/src/longlive_basic_consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -47,13 +47,13 @@ async fn main() {
.unwrap();

// bind the queue to exchange
let rounting_key = "amqprs.example";
let routing_key = "amqprs.example";
let exchange_name = "amq.topic";
channel
.queue_bind(QueueBindArguments::new(
&queue_name,
exchange_name,
rounting_key,
routing_key,
))
.await
.unwrap();
Expand Down

0 comments on commit de21bbe

Please sign in to comment.