summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatus Valo <matusvalo@gmail.com>2020-09-24 16:18:23 +0200
committerMatus Valo <matusvalo@gmail.com>2020-09-24 16:18:23 +0200
commit684b350327051e4b6916779e72b8573da5d0a1e3 (patch)
tree31fff80c47c394d57cada3d9e50b85803a035a29
parentfaa1d86b525e63315026f0607fa522992c003c77 (diff)
downloadkombu-684b350327051e4b6916779e72b8573da5d0a1e3.tar.gz
Fixed examples in failover documentation
-rw-r--r--docs/userguide/failover.rst4
1 files changed, 0 insertions, 4 deletions
diff --git a/docs/userguide/failover.rst b/docs/userguide/failover.rst
index f91ba983..e101f5ec 100644
--- a/docs/userguide/failover.rst
+++ b/docs/userguide/failover.rst
@@ -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: