diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-01-09 04:48:33 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-01-09 04:48:33 +0300 |
| commit | 490bd6b114a8e7ff55fc6577c3c7868c1dfa5d1f (patch) | |
| tree | 8012c164be15b6b2327bbd040914cf71d527744f | |
| parent | be27684a7b8651966530d594ba4ea454878cba8f (diff) | |
| download | rabbitmq-server-git-490bd6b114a8e7ff55fc6577c3c7868c1dfa5d1f.tar.gz | |
Squash a couple of warnings
| -rw-r--r-- | test/single_active_consumer_SUITE.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/single_active_consumer_SUITE.erl b/test/single_active_consumer_SUITE.erl index 07da4a8d08..945229e372 100644 --- a/test/single_active_consumer_SUITE.erl +++ b/test/single_active_consumer_SUITE.erl @@ -124,7 +124,7 @@ fallback_to_another_consumer_when_first_one_is_cancelled(Config) -> [amqp_channel:cast(Ch, Publish, #amqp_msg{payload = <<"foobar">>}) || _X <- lists:seq(1, MessageCount div 2)], {MessagesPerConsumer1, _} = wait_for_messages(MessageCount div 2), - FirstActiveConsumerInList = maps:keys(maps:filter(fun(_CTag, MessageCount) -> MessageCount > 0 end, MessagesPerConsumer1)), + FirstActiveConsumerInList = maps:keys(maps:filter(fun(_CTag, Count) -> Count > 0 end, MessagesPerConsumer1)), ?assertEqual(1, length(FirstActiveConsumerInList)), FirstActiveConsumer = lists:nth(1, FirstActiveConsumerInList), @@ -136,7 +136,7 @@ fallback_to_another_consumer_when_first_one_is_cancelled(Config) -> {MessagesPerConsumer2, _} = wait_for_messages(MessageCount div 2 - 1), SecondActiveConsumerInList = maps:keys(maps:filter( - fun(CTag, MessageCount) -> MessageCount > 0 andalso CTag /= FirstActiveConsumer end, + fun(CTag, Count) -> Count > 0 andalso CTag /= FirstActiveConsumer end, MessagesPerConsumer2) ), ?assertEqual(1, length(SecondActiveConsumerInList)), |