diff --git a/deps/amqp10_client/src/amqp10_client_connection.erl b/deps/amqp10_client/src/amqp10_client_connection.erl index c6d7a6176c..01eeafd57b 100644 --- a/deps/amqp10_client/src/amqp10_client_connection.erl +++ b/deps/amqp10_client/src/amqp10_client_connection.erl @@ -191,8 +191,8 @@ hdr_sent({protocol_header_received, 0, 1, 0, 0}, State) -> end; hdr_sent({protocol_header_received, Protocol, Maj, Min, Rev}, State) -> - ?DBG("Unsupported protocol version: ~b ~b.~b.~b~n", - [Protocol, Maj, Min, Rev]), + error_logger:warning_msg("Unsupported protocol version: ~b ~b.~b.~b~n", + [Protocol, Maj, Min, Rev]), {stop, normal, State}. open_sent(#'v1_0.open'{max_frame_size = MFSz, idle_time_out = Timeout}, @@ -237,7 +237,8 @@ opened(#'v1_0.close'{error = Error}, State = #state{config = Config}) -> _ = send_close(State, none), {stop, normal, State}; opened(Frame, State) -> - ?DBG("UNEXPECTED CONNECTION FRAME ~p~n", [Frame]), + error_logger:warning_msg("Unexpected connection frame ~p when in state ~p ~n", + [Frame, State]), {next_state, opened, State}. close_sent(#'v1_0.close'{}, State) -> diff --git a/deps/amqp10_client/src/amqp10_client_session.erl b/deps/amqp10_client/src/amqp10_client_session.erl index 155f29cc7d..0da9b10c8f 100644 --- a/deps/amqp10_client/src/amqp10_client_session.erl +++ b/deps/amqp10_client/src/amqp10_client_session.erl @@ -399,7 +399,8 @@ mapped(#'v1_0.disposition'{role = true, settled = true, first = {uint, First}, {next_state, mapped, State#state{unsettled = Unsettled}}; mapped(Frame, State) -> - ?DBG("UNHANDLED FRAME ~p~n", [Frame]), + error_logger:warning_msg("Unhandled session frame ~p in state ~p~n", + [Frame, State]), {next_state, mapped, State}. %% mapped/3