diff options
| -rw-r--r-- | src/rabbit_priority_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_priority_queue.erl b/src/rabbit_priority_queue.erl index 9b8b232fec..7439b5bc32 100644 --- a/src/rabbit_priority_queue.erl +++ b/src/rabbit_priority_queue.erl @@ -126,7 +126,7 @@ collapse_recovery(QNames, DupNames, Recovery) -> [dict:fetch(Name, NameToTerms) || Name <- QNames]. priorities(#amqqueue{arguments = Args}) -> - Ints = [long, short, signedint, byte], + Ints = [long, short, signedint, byte, unsignedbyte, unsignedshort, unsignedint], case rabbit_misc:table_lookup(Args, <<"x-max-priority">>) of {Type, Max} -> case lists:member(Type, Ints) of false -> none; |