Skip to content

Commit cd91867

Browse files
committed
Demonstrate consumer cancelling in consume_500 example.
1 parent 703ca07 commit cd91867

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

README.md

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,8 @@ require 'rabbitmq'
5050

5151
consumer = RabbitMQ::Client.new.start.channel
5252
consumer.basic_qos(prefetch_count: 500)
53-
consumer.basic_consume("some_queue")
53+
res = consumer.basic_consume("some_queue")
54+
tag = res[:properties][:consumer_tag]
5455

5556
count = 0
5657
consumer.on :basic_deliver do |message|
@@ -62,6 +63,7 @@ consumer.on :basic_deliver do |message|
6263
end
6364

6465
consumer.run_loop!
66+
consumer.basic_cancel(tag)
6567
```
6668

6769
## Contributing

example/consume_500.rb

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,8 @@
33

44
consumer = RabbitMQ::Client.new.start.channel
55
consumer.basic_qos(prefetch_count: 500)
6-
consumer.basic_consume("some_queue")
6+
res = consumer.basic_consume("some_queue")
7+
tag = res[:properties][:consumer_tag]
78

89
count = 0
910
consumer.on :basic_deliver do |message|
@@ -15,3 +16,4 @@
1516
end
1617

1718
consumer.run_loop!
19+
consumer.basic_cancel(tag)

0 commit comments

Comments
 (0)