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 | 3b006dcd66be7a3c97e4c24ddfbd2d9903636070 (patch) | |
| tree | 7268a16370d4c97c2cffb3cd70e1f768ea4d5b8a | |
| parent | 5d7b2218e20c93235c1f2b05699f306f52f5429c (diff) | |
| parent | ff9805c263078b4a7a3de5916885f06b0a3e9557 (diff) | |
| download | rabbitmq-server-3b006dcd66be7a3c97e4c24ddfbd2d9903636070.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 1e32f95a..6a09573c 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) -> |