diff options
Diffstat (limited to 'deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session_process.erl')
| -rw-r--r-- | deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session_process.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session_process.erl b/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session_process.erl index e8bc5505e6..d1899ece06 100644 --- a/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session_process.erl +++ b/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session_process.erl @@ -57,12 +57,12 @@ init({Channel, ReaderPid, WriterPid, #user{username = Username}, VHost, session = rabbit_amqp1_0_session:init(Channel) }}; {error, Reason} -> - rabbit_log:warning("Closing session for connection ~p:~n~p~n", + rabbit_log:warning("Closing session for connection ~p:~n~p", [ReaderPid, Reason]), {stop, Reason} end; {error, Reason} -> - rabbit_log:warning("Closing session for connection ~p:~n~p~n", + rabbit_log:warning("Closing session for connection ~p:~n~p", [ReaderPid, Reason]), {stop, Reason} end. @@ -158,7 +158,7 @@ handle_info({'DOWN', _MRef, process, Ch, Reason}, io_lib:format("~w", [Reason])))}} end, End = #'v1_0.end'{ error = Error }, - rabbit_log:warning("Closing session for connection ~p:~n~p~n", + rabbit_log:warning("Closing session for connection ~p:~n~p", [ReaderPid, Reason]), ok = rabbit_amqp1_0_writer:send_command_sync(Sock, End), {stop, normal, State}; @@ -186,7 +186,7 @@ handle_cast({frame, Frame, FlowPid}, catch exit:Reason = #'v1_0.error'{} -> %% TODO shut down nicely like rabbit_channel End = #'v1_0.end'{ error = Reason }, - rabbit_log:warning("Closing session for connection ~p:~n~p~n", + rabbit_log:warning("Closing session for connection ~p:~n~p", [ReaderPid, Reason]), ok = rabbit_amqp1_0_writer:send_command_sync(Sock, End), {stop, normal, State}; @@ -286,7 +286,7 @@ handle_control(#'v1_0.disposition'{state = Outcome, protocol_error( ?V_1_0_AMQP_ERROR_INVALID_FIELD, "Unrecognised state: ~p~n" - "Disposition was: ~p~n", [Outcome, Disp]) + "Disposition was: ~p", [Outcome, Disp]) end) end, case rabbit_amqp1_0_session:settle(Disp, session(State), AckFun) of |