Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed examples in failover documentation

This commit is contained in:
Matus Valo 2020-09-24 16:18:23 +02:00
parent faa1d86b52
commit 684b350327
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
docs/userguide/failover.rst
View File

@ -99,8 +99,6 @@ Consumer with failover functionality can be implemented using following function
>>> def consume():
... while True:
... drain_events = conn.ensure(
... conn, conn.drain_events)
... try:
... conn.drain_events(timeout=1)
... except socket.timeout:
@ -129,8 +127,6 @@ The full example implementing consumer with failover is as follows:
>>> with Connection('amqp://broker1:5672;amqp://broker2:5672') as conn:
... def consume():
... while True:
... drain_events = conn.ensure(
... conn, conn.drain_events)
... try:
... conn.drain_events(timeout=1)
... except socket.timeout: