Skip to content

Commit d4ea90d

Browse files
committed
Simplify
Protect only `rabbit_mqtt_processor:handle_queue_event/2` since only that call might throw a `{send_failed, Reaso}`.
1 parent f398892 commit d4ea90d

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

deps/rabbitmq_mqtt/src/rabbit_mqtt_reader.erl

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -140,13 +140,11 @@ handle_cast({close_connection, Reason},
140140

141141
handle_cast(QueueEvent = {queue_event, _, _},
142142
State = #state{proc_state = PState0}) ->
143-
try
144-
case rabbit_mqtt_processor:handle_queue_event(QueueEvent, PState0) of
145-
{ok, PState} ->
146-
maybe_process_deferred_recv(control_throttle(pstate(State, PState)));
147-
{error, Reason0, PState} ->
148-
{stop, Reason0, pstate(State, PState)}
149-
end
143+
try rabbit_mqtt_processor:handle_queue_event(QueueEvent, PState0) of
144+
{ok, PState} ->
145+
maybe_process_deferred_recv(control_throttle(pstate(State, PState)));
146+
{error, Reason0, PState} ->
147+
{stop, Reason0, pstate(State, PState)}
150148
catch throw:{send_failed, Reason1} ->
151149
network_error(Reason1, State)
152150
end;

0 commit comments

Comments
 (0)