diff options
| author | kjnilsson <knilsson@pivotal.io> | 2021-01-20 14:27:37 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2021-01-20 14:27:37 +0000 |
| commit | 6d1f3a160be772e1d53ab431f6b47540d912141c (patch) | |
| tree | c8299d52eb22cacec5ec8be01302f355386fedb1 | |
| parent | f2418cfe4ca634753c5db518c1bd034ce6cfe771 (diff) | |
| download | rabbitmq-server-git-qq-bug-fix-service-queue-conv.tar.gz | |
rabbit_fifo: handle unhandled commandsqq-bug-fix-service-queue-conv
To avoid crashes.
| -rw-r--r-- | deps/rabbit/src/rabbit_fifo.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/deps/rabbit/src/rabbit_fifo.erl b/deps/rabbit/src/rabbit_fifo.erl index 6232a21574..37aece9d6c 100644 --- a/deps/rabbit/src/rabbit_fifo.erl +++ b/deps/rabbit/src/rabbit_fifo.erl @@ -512,6 +512,10 @@ apply(Meta, #update_config{config = Conf}, State) -> checkout(Meta, State, update_config(Conf, State), []); apply(_Meta, {machine_version, 0, 1}, V0State) -> State = convert_v0_to_v1(V0State), + {State, ok, []}; +apply(_Meta, Cmd, State) -> + %% handle unhandled commands gracefully + rabbit_log:debug("rabbit_fifo: unhandled command ~W", [Cmd, 10]), {State, ok, []}. convert_v0_to_v1(V0State0) -> |