diff options
author | Matus Valo <matusvalo@gmail.com> | 2020-09-24 16:18:23 +0200 |
---|---|---|
committer | Matus Valo <matusvalo@gmail.com> | 2020-09-24 16:18:23 +0200 |
commit | 684b350327051e4b6916779e72b8573da5d0a1e3 (patch) | |
tree | 31fff80c47c394d57cada3d9e50b85803a035a29 | |
parent | faa1d86b525e63315026f0607fa522992c003c77 (diff) | |
download | kombu-684b350327051e4b6916779e72b8573da5d0a1e3.tar.gz |
Fixed examples in failover documentation
-rw-r--r-- | docs/userguide/failover.rst | 4 |
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: |