diff options
| -rw-r--r-- | src/rabbit_limiter.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_tests.erl | 5 |
2 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 9457f7d0ae..1104d33c2e 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -35,7 +35,7 @@ -opaque(token() :: #token{}). -spec(start_link/0 :: () -> rabbit_types:ok_pid_or_error()). --spec(make_token/1 :: (pid()) -> token()). +-spec(make_token/1 :: (undefined | pid()) -> token()). -spec(is_enabled/1 :: (token()) -> boolean()). -spec(enable/2 :: (token(), non_neg_integer()) -> token()). -spec(disable/1 :: (token()) -> token()). diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index 6266b5efec..0ee59e1e60 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -1206,8 +1206,9 @@ test_server_status() -> rabbit_misc:r(<<"/">>, queue, Name), false, false, [], none)]], - ok = rabbit_amqqueue:basic_consume(Q, true, Ch, undefined, - <<"ctag">>, true, undefined), + ok = rabbit_amqqueue:basic_consume( + Q, true, Ch, rabbit_limiter:make_token(undefined), + <<"ctag">>, true, undefined), %% list queues ok = info_action(list_queues, rabbit_amqqueue:info_keys(), true), |