diff options
| author | Philip Kuryloski <kuryloskip@vmware.com> | 2020-06-02 14:33:02 +0200 |
|---|---|---|
| committer | Philip Kuryloski <kuryloskip@vmware.com> | 2020-06-02 14:33:02 +0200 |
| commit | 30bd4bb0a62b59775780f66ce0bde461ebc4a41b (patch) | |
| tree | 6075bd6552b8dcda0ee73d00cbe2fa7a243d7da5 | |
| parent | 9083a01b59195bf1202b74f504b5ae47ba110a6a (diff) | |
| download | rabbitmq-server-git-30bd4bb0a62b59775780f66ce0bde461ebc4a41b.tar.gz | |
Use the newly defined MSG_STORE_WORKER_WAIT for rabbit_msg_store
In order raise the default timeout for gracefully shutting down message stores, without affecting a larger set of supervisors, introduce a specific macro for this case
| -rw-r--r-- | src/rabbit_vhost_msg_store.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_vhost_msg_store.erl b/src/rabbit_vhost_msg_store.erl index 492c9ce5c7..6bdd33ec1a 100644 --- a/src/rabbit_vhost_msg_store.erl +++ b/src/rabbit_vhost_msg_store.erl @@ -29,7 +29,7 @@ start(VHost, Type, ClientRefs, StartupFunState) when is_list(ClientRefs); supervisor2:start_child(VHostSup, {Type, {rabbit_msg_store, start_link, [Type, VHostDir, ClientRefs, StartupFunState]}, - transient, ?WORKER_WAIT, worker, [rabbit_msg_store]}); + transient, ?MSG_STORE_WORKER_WAIT, worker, [rabbit_msg_store]}); %% we can get here if a vhost is added and removed concurrently %% e.g. some integration tests do it {error, {no_such_vhost, VHost}} = E -> |