Skip to content

Commit b8f4373

Browse files
committed
Fix crash in MQTT reader
Fix the following crash: ``` crasher: initial call: rabbit_mqtt_reader:init/1 pid: <0.2009.0> registered_name: [] exception exit: {bad_return_value, {stop, {shutdown,consuming_queue_down, {state,#Port<0.163>,undefined,true,undefined,4, {state, ```
1 parent 7fad984 commit b8f4373

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbitmq_mqtt/src/rabbit_mqtt_reader.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ handle_info({{'DOWN', _QName}, _MRef, process, _Pid, _Reason} = Evt,
249249
{ok, PState} ->
250250
maybe_process_deferred_recv(control_throttle(pstate(State, PState)));
251251
{error, Reason} ->
252-
{stop, {shutdown, Reason, State}}
252+
{stop, {shutdown, Reason}, State}
253253
end;
254254

255255
handle_info({'DOWN', _MRef, process, QPid, _Reason}, State) ->

0 commit comments

Comments
 (0)