diff options
Diffstat (limited to 'deps/amqp10_client/src/amqp10_client_connection.erl')
| -rw-r--r-- | deps/amqp10_client/src/amqp10_client_connection.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/deps/amqp10_client/src/amqp10_client_connection.erl b/deps/amqp10_client/src/amqp10_client_connection.erl index 023b3d8dc9..c56cde2c6e 100644 --- a/deps/amqp10_client/src/amqp10_client_connection.erl +++ b/deps/amqp10_client/src/amqp10_client_connection.erl @@ -228,7 +228,7 @@ hdr_sent(_EvtType, {protocol_header_received, 0, 1, 0, 0}, State) -> end; hdr_sent(_EvtType, {protocol_header_received, Protocol, Maj, Min, Rev}, State) -> - error_logger:warning_msg("Unsupported protocol version: ~b ~b.~b.~b~n", + logger:warning("Unsupported protocol version: ~b ~b.~b.~b", [Protocol, Maj, Min, Rev]), {stop, normal, State}; hdr_sent({call, From}, begin_session, @@ -291,7 +291,7 @@ opened(info, {'DOWN', MRef, _, _, _Info}, ok = notify_closed(Config, shutdown), {stop, normal, State}; opened(_EvtType, Frame, State) -> - error_logger:warning_msg("Unexpected connection frame ~p when in state ~p ~n", + logger:warning("Unexpected connection frame ~p when in state ~p ", [Frame, State]), {keep_state, State}. @@ -367,7 +367,7 @@ send_open(#state{socket = Socket, config = Config}) -> end, Encoded = amqp10_framing:encode_bin(Open), Frame = amqp10_binary_generator:build_frame(0, Encoded), - ?DBG("CONN <- ~p~n", [Open]), + ?DBG("CONN <- ~p", [Open]), socket_send(Socket, Frame). @@ -375,7 +375,7 @@ send_close(#state{socket = Socket}, _Reason) -> Close = #'v1_0.close'{}, Encoded = amqp10_framing:encode_bin(Close), Frame = amqp10_binary_generator:build_frame(0, Encoded), - ?DBG("CONN <- ~p~n", [Close]), + ?DBG("CONN <- ~p", [Close]), Ret = socket_send(Socket, Frame), case Ret of ok -> _ = @@ -397,7 +397,7 @@ send_sasl_init(State, {plain, User, Pass}) -> send(Record, FrameType, #state{socket = Socket}) -> Encoded = amqp10_framing:encode_bin(Record), Frame = amqp10_binary_generator:build_frame(0, FrameType, Encoded), - ?DBG("CONN <- ~p~n", [Record]), + ?DBG("CONN <- ~p", [Record]), socket_send(Socket, Frame). send_heartbeat(#state{socket = Socket}) -> |