diff options
| -rw-r--r-- | src/rabbit_disk_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index 0623d77d24..510a8590b6 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -95,10 +95,10 @@ tx_cancel(MsgIds) when is_list(MsgIds) -> gen_server:cast(?SERVER, {tx_cancel, MsgIds}). stop() -> - gen_server:call(?SERVER, stop). + gen_server:call(?SERVER, stop, infinity). clean_stop() -> - gen_server:call(?SERVER, clean_stop). + gen_server:call(?SERVER, clean_stop, infinity). %% ---- GEN-SERVER INTERNAL API ---- |