Skip to content
This repository was archived by the owner on Nov 17, 2020. It is now read-only.

Commit 1b0f3a1

Browse files
committed
Remove a duplicate control_throttle
The function is already called before calling process_received_bytes, there doesn't seem to be a reason to call it again.
1 parent d24ebc1 commit 1b0f3a1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/rabbit_mqtt_reader.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ process_received_bytes(Bytes,
261261
case parse(Bytes, ParseState) of
262262
{more, ParseState1} ->
263263
{noreply,
264-
ensure_stats_timer(control_throttle( State #state{ parse_state = ParseState1 })),
264+
ensure_stats_timer( State #state{ parse_state = ParseState1 }),
265265
hibernate};
266266
{ok, Frame, Rest} ->
267267
case rabbit_mqtt_processor:process_frame(Frame, ProcState) of

0 commit comments

Comments
 (0)