Skip to content

Commit b30ae2f

Browse files
Wording, compile from scratch
1 parent a82bdad commit b30ae2f

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

src/rabbit_amqqueue.erl

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -837,20 +837,22 @@ delete_immediately(QPids) ->
837837

838838
delete(Q, IfUnused, IfEmpty, ActingUser) ->
839839
case wait_for_promoted_or_stopped(Q) of
840-
{promoted, Q1 = #amqqueue{pid = QPid}} ->
840+
{promoted, #amqqueue{pid = QPid}} ->
841841
delegate:invoke(QPid, {gen_server2, call, [{delete, IfUnused, IfEmpty, ActingUser}, infinity]});
842842
{stopped, Q1} ->
843843
#resource{name = Name, virtual_host = Vhost} = Q1#amqqueue.name,
844844
case IfEmpty of
845845
true ->
846-
rabbit_log:error("Queue ~s on vhost ~s master node is down. "
847-
"The queue may be not empty. "
846+
rabbit_log:error("Queue ~s in vhost ~s has its master node down and "
847+
"no mirrors available or eligible for promotion. "
848+
"The queue may be non-empty. "
848849
"Refusing to force-delete.",
849850
[Name, Vhost]),
850851
{error, not_empty};
851852
false ->
852-
rabbit_log:warning("Queue ~s on vhost ~s master node is down. "
853-
"Force-deleting the queue.",
853+
rabbit_log:warning("Queue ~s in vhost ~s has its master node is down and "
854+
"no mirrors available or eligible for promotion. "
855+
"Forcing queue deletion.",
854856
[Name, Vhost]),
855857
delete_crashed_internal(Q1, ActingUser),
856858
{ok, 0}

0 commit comments

Comments
 (0)