Skip to content

Commit 03228a7

Browse files
Merge pull request #9996 from rabbitmq/mergify/bp/v3.12.x/pr-9994
rabbit_writer: ignore unknown messages (backport #9994)
2 parents 8a45b24 + 0c742bb commit 03228a7

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

deps/rabbit_common/src/rabbit_writer.erl

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -275,6 +275,14 @@ handle_message({inet_reply, _, Status}, _State) ->
275275
handle_message(emit_stats, State = #wstate{reader = ReaderPid}) ->
276276
ReaderPid ! ensure_stats,
277277
rabbit_event:reset_stats_timer(State, #wstate.stats_timer);
278+
handle_message(ok, State) ->
279+
State;
280+
handle_message({_Ref, ok} = Msg, State) ->
281+
rabbit_log:warning("AMQP 0-9-1 channel writer has received a message it does not support: ~p", [Msg]),
282+
State;
283+
handle_message({ok, _Ref} = Msg, State) ->
284+
rabbit_log:warning("AMQP 0-9-1 channel writer has received a message it does not support: ~p", [Msg]),
285+
State;
278286
handle_message(Message, _State) ->
279287
exit({writer, message_not_understood, Message}).
280288

0 commit comments

Comments
 (0)