diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/channel_interceptor_SUITE.erl | 14 | ||||
| -rw-r--r-- | test/failing_dummy_interceptor.erl | 27 |
2 files changed, 36 insertions, 5 deletions
diff --git a/test/channel_interceptor_SUITE.erl b/test/channel_interceptor_SUITE.erl index 0e4948ea3c..4081086f4f 100644 --- a/test/channel_interceptor_SUITE.erl +++ b/test/channel_interceptor_SUITE.erl @@ -29,7 +29,8 @@ all() -> groups() -> [ {non_parallel_tests, [], [ - register_interceptor + register_interceptor, + register_failing_interceptors ]} ]. @@ -71,9 +72,9 @@ end_per_testcase(Testcase, Config) -> register_interceptor(Config) -> passed = rabbit_ct_broker_helpers:rpc(Config, 0, - ?MODULE, register_interceptor1, [Config]). + ?MODULE, register_interceptor1, [Config, dummy_interceptor]). -register_interceptor1(Config) -> +register_interceptor1(Config, Interceptor) -> PredefinedChannels = rabbit_channel:list(), Ch1 = rabbit_ct_client_helpers:open_channel(Config, 0), @@ -89,8 +90,8 @@ register_interceptor1(Config) -> ok = rabbit_registry:register(channel_interceptor, <<"dummy interceptor">>, - dummy_interceptor), - [{interceptors, [{dummy_interceptor, undefined}]}] = + Interceptor), + [{interceptors, [{Interceptor, undefined}]}] = rabbit_channel:info(ChannelProc, [interceptors]), check_send_receive(Ch1, QName, <<"bar">>, <<"">>), @@ -102,6 +103,9 @@ register_interceptor1(Config) -> check_send_receive(Ch1, QName, <<"bar">>, <<"bar">>), passed. +register_failing_interceptors(Config) -> + passed = rabbit_ct_broker_helpers:rpc(Config, 0, + ?MODULE, register_interceptor1, [Config, failing_dummy_interceptor]). check_send_receive(Ch1, QName, Send, Receive) -> amqp_channel:call(Ch1, diff --git a/test/failing_dummy_interceptor.erl b/test/failing_dummy_interceptor.erl new file mode 100644 index 0000000000..62669e7f1f --- /dev/null +++ b/test/failing_dummy_interceptor.erl @@ -0,0 +1,27 @@ +-module(failing_dummy_interceptor). + +-behaviour(rabbit_channel_interceptor). + +-include_lib("rabbit_common/include/rabbit.hrl"). +-include_lib("rabbit_common/include/rabbit_framing.hrl"). + + +-compile(export_all). + +init(_Ch) -> + timer:sleep(15500), + undefined. + +description() -> + [{description, + <<"Empties payload on publish">>}]. + +intercept(#'basic.publish'{} = Method, Content, _IState) -> + Content2 = Content#content{payload_fragments_rev = []}, + {Method, Content2}; + +intercept(Method, Content, _VHost) -> + {Method, Content}. + +applies_to() -> + ['basic.publish']. |