Clean events from handler between tests

Author: acogoluegnes

deps/rabbit/test/rabbit_list_test_event_handler.erl

@@ -19,7 +19,7 @@
 
 -behaviour(gen_event).
 
--export([start_link/0, stop/0, get_events/0]).
+-export([start_link/0, stop/0, get_events/0, clear_events/0]).
 
 %% callbacks
 -export([init/1, handle_event/2, handle_call/2, handle_info/2, terminate/2, code_change/3]).
@@ -33,6 +33,9 @@ stop() ->
 get_events() ->
     gen_event:call(?MODULE, ?MODULE, get_events).
 
+clear_events() ->
+    gen_event:call(?MODULE, ?MODULE, clear_events).
+
 %% Callbacks
 
 init([]) ->
@@ -42,7 +45,9 @@ handle_event(Event, State) ->
     {ok, [Event | State]}.
 
 handle_call(get_events, State) ->
-    {ok, lists:reverse(State), State}.
+    {ok, lists:reverse(State), State};
+handle_call(clear_events, _) ->
+    {ok, ok, []}.
 
 handle_info(_Info, State) ->
     {ok, State}.

deps/rabbit/test/rabbit_stream_queue_SUITE.erl

@@ -1229,6 +1229,12 @@ consume_cancel_should_create_events(Config) ->
     {ok, Ch} = amqp_connection:open_channel(Conn),
     qos(Ch, 10, false),
 
+
+    ok = rabbit_ct_broker_helpers:rpc(Config, 0,
+                                      gen_event,
+                                      call,
+                                      [rabbit_event, HandlerMod, clear_events]),
+
     ?assertEqual([], filtered_events(Config, consumer_created)),
     ?assertEqual([], filtered_events(Config, consumer_deleted)),