diff options
| author | Daniil Fedotov <dfedotov@pivotal.io> | 2017-03-08 13:25:51 +0000 |
|---|---|---|
| committer | Daniil Fedotov <dfedotov@pivotal.io> | 2017-03-08 13:25:51 +0000 |
| commit | 6330cb3b01f54faa2937cb8e1c712f3d8f235323 (patch) | |
| tree | 81de29c3e06a59dd7425526b84d52c62669dae07 | |
| parent | e18cd0682c8f0085a5521462cf79c7cdb5cf91fd (diff) | |
| download | rabbitmq-server-git-6330cb3b01f54faa2937cb8e1c712f3d8f235323.tar.gz | |
Log message store stopping
| -rw-r--r-- | src/rabbit_msg_store.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 5e2e43a73d..9df5ba79c2 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -985,6 +985,7 @@ terminate(_Reason, State = #msstate { index_state = IndexState, flying_ets = FlyingEts, clients = Clients, dir = Dir }) -> + rabbit_log:info("Stopping message store for directory ~p", [Dir]), %% stop the gc first, otherwise it could be working and we pull %% out the ets tables from under it. ok = rabbit_msg_store_gc:stop(GCPid), @@ -1001,6 +1002,7 @@ terminate(_Reason, State = #msstate { index_state = IndexState, IndexModule:terminate(IndexState), ok = store_recovery_terms([{client_refs, dict:fetch_keys(Clients)}, {index_module, IndexModule}], Dir), + rabbit_log:info("Message store is stopped for directory ~p", [Dir]), State3 #msstate { index_state = undefined, current_file_handle = undefined }. |