diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_exchange.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 21dd4db40f..d8b1cbc85b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -963,7 +963,7 @@ i(reductions, _State) -> {reductions, Reductions} = erlang:process_info(self(), reductions), Reductions; i(user_who_performed_action, #q{q = #amqqueue{options = Opts}}) -> - maps:get(user, Opts); + maps:get(user, Opts, ?UNKNOWN_USER); i(Item, #q{backing_queue_state = BQS, backing_queue = BQ}) -> BQ:info(Item, BQS). diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index d5a9afbeca..85f061a17b 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -346,7 +346,7 @@ i(policy, X) -> case rabbit_policy:name(X) of Policy -> Policy end; i(user_who_performed_action, #exchange{options = Opts}) -> - maps:get(user, Opts); + maps:get(user, Opts, ?UNKNOWN_USER); i(Item, #exchange{type = Type} = X) -> case (type_to_module(Type)):info(X, [Item]) of [{Item, I}] -> I; |