blob: 62669e7f1f94596e3b68d6d5d4eb678a7d4f631d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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'].
|
