diff options
| author | Michael Klishin <michael@novemberain.com> | 2016-08-10 10:04:22 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-08-10 10:04:22 +0100 |
| commit | ca4c0c011f963b4511da111261bb48bdd3dabad2 (patch) | |
| tree | 2016fae8c7e1c64324b37428f7093037ed004bbc | |
| parent | 065f31d3d878f887bb811db0c5a49029a3f057ef (diff) | |
| parent | 1c4934df5b22df0ae6a5496bcd40d8b954dbfcac (diff) | |
| download | rabbitmq-server-git-ca4c0c011f963b4511da111261bb48bdd3dabad2.tar.gz | |
Merge pull request #910 from rabbitmq/rabbitmq-server-850
Added resume after flow
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 9ad752a174..297df086ad 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -939,7 +939,7 @@ convert_to_lazy(State) -> %% is not in a proper state for a lazy BQ (unless all %% messages have been paged to disk already). wait_for_msg_store_credit(), - convert_to_lazy(State1) + convert_to_lazy(resume(State1)) end. wait_for_msg_store_credit() -> |