diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-06-24 11:01:15 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-06-24 11:01:15 +0100 |
| commit | 2398b25282e9a8516b074c8ca322d5b7600311e3 (patch) | |
| tree | 7268a16370d4c97c2cffb3cd70e1f768ea4d5b8a | |
| parent | d6c429f8f153273d668e6f2120fa8bd1401578cd (diff) | |
| parent | a3fc8002e074b8391b6b6cf3468734dfdd0b3447 (diff) | |
| download | rabbitmq-server-git-2398b25282e9a8516b074c8ca322d5b7600311e3.tar.gz | |
stable to default
| -rw-r--r-- | src/rabbit_limiter.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 1e32f95a3d..6a09573c62 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -255,7 +255,9 @@ safe_call(Pid, Msg, ExitValue) -> fun () -> ExitValue end, fun () -> gen_server2:call(Pid, Msg, infinity) end). -resume(L) -> L#qstate{state = active}. +resume(L = #qstate{state = suspended}) -> + L#qstate{state = active}; +resume(L) -> L. deactivate(L = #qstate{state = dormant}) -> L; deactivate(L) -> |