diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 04728a030b..16d134017f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -885,12 +885,8 @@ already_been_here(Delivery = #delivery{message = #basic_message{content = Conten {array, DeathTables} -> OldQueues = [rabbit_misc:table_lookup(D, <<"queue">>) || {table, D} <- DeathTables], - OldQueues1 = lists:append( - lists:map(fun (undefined) -> []; - ({longstr, QName}) -> [QName] - end, OldQueues)), - case lists:any(fun(QName) -> QName == QueueName end, - OldQueues1) of + OldQueues1 = [QName || {longstr, QName} <- OldQueues], + case lists:member(QueueName, OldQueues1) of true -> [QueueName | OldQueues1]; _ -> false end; |