Skip to content

Commit a0f8944

Browse files
Michal Kuratczykmkuratczyk
authored andcommitted
Fix LOG macro continuation line indentation in core files
Fixed alignment in: - amqp_channel.erl: 3 instances - amqp_gen_connection.erl: 2 instances - rabbit_fifo_client.erl: 2 instances Continuation lines now properly align with the opening quote.
1 parent cd1b401 commit a0f8944

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

deps/amqp_client/src/amqp_channel.erl

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -516,7 +516,7 @@ handle_info({bump_credit, Msg}, State) ->
516516
%% @private
517517
handle_info(timed_out_flushing_channel, State) ->
518518
?LOG_WARNING("Channel (~tp) closing: timed out flushing while "
519-
"connection closing", [self()]),
519+
"connection closing", [self()]),
520520
{stop, timed_out_flushing_channel, State};
521521
%% @private
522522
handle_info({'DOWN', _, process, ReturnHandler, shutdown},
@@ -525,7 +525,7 @@ handle_info({'DOWN', _, process, ReturnHandler, shutdown},
525525
handle_info({'DOWN', _, process, ReturnHandler, Reason},
526526
State = #state{return_handler = {ReturnHandler, _Ref}}) ->
527527
?LOG_WARNING("Channel (~tp): Unregistering return handler ~tp because it died. "
528-
"Reason: ~tp", [self(), ReturnHandler, Reason]),
528+
"Reason: ~tp", [self(), ReturnHandler, Reason]),
529529
{noreply, State#state{return_handler = none}};
530530
%% @private
531531
handle_info({'DOWN', _, process, ConfirmHandler, shutdown},
@@ -534,7 +534,7 @@ handle_info({'DOWN', _, process, ConfirmHandler, shutdown},
534534
handle_info({'DOWN', _, process, ConfirmHandler, Reason},
535535
State = #state{confirm_handler = {ConfirmHandler, _Ref}}) ->
536536
?LOG_WARNING("Channel (~tp): Unregistering confirm handler ~tp because it died. "
537-
"Reason: ~tp", [self(), ConfirmHandler, Reason]),
537+
"Reason: ~tp", [self(), ConfirmHandler, Reason]),
538538
{noreply, State#state{confirm_handler = none}};
539539
%% @private
540540
handle_info({'DOWN', _, process, FlowHandler, shutdown},
@@ -543,7 +543,7 @@ handle_info({'DOWN', _, process, FlowHandler, shutdown},
543543
handle_info({'DOWN', _, process, FlowHandler, Reason},
544544
State = #state{flow_handler = {FlowHandler, _Ref}}) ->
545545
?LOG_WARNING("Channel (~tp): Unregistering flow handler ~tp because it died. "
546-
"Reason: ~tp", [self(), FlowHandler, Reason]),
546+
"Reason: ~tp", [self(), FlowHandler, Reason]),
547547
{noreply, State#state{flow_handler = none}};
548548
handle_info({'DOWN', _, process, QPid, _Reason}, State) ->
549549
rabbit_amqqueue_common:notify_sent_queue_down(QPid),

deps/amqp_client/src/amqp_gen_connection.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -207,12 +207,12 @@ handle_cast({register_blocked_handler, HandlerPid}, State) ->
207207
handle_info({'DOWN', _, process, BlockHandler, Reason},
208208
State = #state{block_handler = {BlockHandler, _Ref}}) ->
209209
?LOG_WARNING("Connection (~tp): Unregistering connection.{blocked,unblocked} handler ~tp because it died. "
210-
"Reason: ~tp", [self(), BlockHandler, Reason]),
210+
"Reason: ~tp", [self(), BlockHandler, Reason]),
211211
{noreply, State#state{block_handler = none}};
212212
handle_info({'EXIT', BlockHandler, Reason},
213213
State = #state{block_handler = {BlockHandler, Ref}}) ->
214214
?LOG_WARNING("Connection (~tp): Unregistering connection.{blocked,unblocked} handler ~tp because it died. "
215-
"Reason: ~tp", [self(), BlockHandler, Reason]),
215+
"Reason: ~tp", [self(), BlockHandler, Reason]),
216216
erlang:demonitor(Ref, [flush]),
217217
{noreply, State#state{block_handler = none}};
218218
%% propagate the exit to the module that will stop with a sensible reason logged

deps/rabbit/src/rabbit_fifo_client.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,13 +147,13 @@ enqueue(QName, Correlation, Msg,
147147
{reject_publish, State0};
148148
{error, {shutdown, delete}} ->
149149
?LOG_DEBUG("~ts: QQ ~ts tried to register enqueuer during delete shutdown",
150-
[?MODULE, rabbit_misc:rs(QName)]),
150+
[?MODULE, rabbit_misc:rs(QName)]),
151151
{reject_publish, State0};
152152
{timeout, _} ->
153153
{reject_publish, State0};
154154
Err ->
155155
?LOG_DEBUG("~ts: QQ ~ts error when registering enqueuer ~p",
156-
[?MODULE, rabbit_misc:rs(QName), Err]),
156+
[?MODULE, rabbit_misc:rs(QName), Err]),
157157
exit(Err)
158158
end;
159159
enqueue(_QName, _Correlation, _Msg,

0 commit comments

Comments
 (0)