Skip to content

Commit

Permalink
Update log messages
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelklishin committed Oct 26, 2020
1 parent 8f9f283 commit 64abde0
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions src/rabbit_delayed_message.erl
Original file line number Diff line number Diff line change
Expand Up @@ -224,14 +224,14 @@ recover() ->
%% starting with RabbitMQ 3.8.4
case list_exchanges() of
{ok, Xs} ->
rabbit_log:debug("Delayed message exchange:
have ~b durable exchanges to recover",
rabbit_log:debug("Delayed message exchange: "
"have ~b durable exchanges to recover",
[length(Xs)]),
[recover_exchange_and_bindings(X) || X <- lists:usort(Xs)];
{aborted, Reason} ->
rabbit_log:error(
"Delayed message exchange:
failed to recover durable exchange ring state, reason: ~p",
"Delayed message exchange: "
"failed to recover durable bindings of one of the exchanges, reason: ~p",
[Reason])
end.

Expand All @@ -255,7 +255,7 @@ recover_exchange_and_bindings(#exchange{name = XName} = X) ->
Bindings = rabbit_binding:list_for_source(XName),
[rabbit_exchange_type_delayed_message:add_binding(transaction, X, B)
|| B <- lists:usort(Bindings)],
rabbit_log:debug("Delayed message exchange:
recovered bindings for exchange ~s",
rabbit_log:debug("Delayed message exchange: "
"recovered bindings for ~s",
[rabbit_misc:rs(XName)])
end).

0 comments on commit 64abde0

Please sign in to comment.