Skip to content

Commit 7d06f80

Browse files
dcorbachodumbbell
authored andcommitted
Mqtt: filter test events
1 parent 2209b0b commit 7d06f80

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

deps/rabbitmq_mqtt/test/reader_SUITE.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -243,7 +243,7 @@ event_authentication_failure(Config) ->
243243

244244
?assertMatch({error, _}, emqtt:connect(C)),
245245

246-
[E] = util:get_events(Server),
246+
[E | _] = util:get_events(Server, user_authentication_failure),
247247
util:assert_event_type(user_authentication_failure, E),
248248
util:assert_event_prop([{name, <<"Trudy">>},
249249
{connection_type, network}],

deps/rabbitmq_mqtt/test/util.erl

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
connect/4,
2020
start_client/4,
2121
get_events/1,
22+
get_events/2,
2223
assert_event_type/2,
2324
assert_event_prop/2,
2425
assert_message_expiry_interval/2,
@@ -104,6 +105,11 @@ get_events(Node) ->
104105
?assert(is_list(Result)),
105106
Result.
106107

108+
get_events(Node, Type) ->
109+
lists:filter(fun(#event{type = T}) ->
110+
T == Type
111+
end, get_events(Node)).
112+
107113
assert_event_type(ExpectedType, #event{type = ActualType}) ->
108114
?assertEqual(ExpectedType, ActualType).
109115

0 commit comments

Comments
 (0)