diff options
Diffstat (limited to 'python/qpid')
| -rw-r--r-- | python/qpid/driver.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/qpid/driver.py b/python/qpid/driver.py index 6ac5c0e04f..4f001974d4 100644 --- a/python/qpid/driver.py +++ b/python/qpid/driver.py @@ -702,6 +702,7 @@ class Driver: sst.write_cmd(MessageStop(rcv.destination, sync=True), do_stop) if rcv.draining: + _rcv.draining = True def do_flush(): rcv.impending = rcv.received rcv.granted = rcv.impending |