diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2013-12-19 23:38:14 +0100 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2013-12-19 23:38:14 +0100 |
| commit | b0f473315261308a7159542d0ed2b338404ba803 (patch) | |
| tree | 74770b63bf9cc99eb921b86edf6d62e3bafcb661 /src/rabbit_channel_interceptor.erl | |
| parent | 4bd69c68ef10817595c268d3ccb5b5c2a661cff7 (diff) | |
| download | rabbitmq-server-b0f473315261308a7159542d0ed2b338404ba803.tar.gz | |
basic.publish performance degrades if called with intercept_method
./runjava.sh com.rabbitmq.examples.PerfTest -y0 yields around 75k msgs/sec
without this change it yields 62k msgs/sec max
and that?s without any interceptor registered
Diffstat (limited to 'src/rabbit_channel_interceptor.erl')
| -rw-r--r-- | src/rabbit_channel_interceptor.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_channel_interceptor.erl b/src/rabbit_channel_interceptor.erl index 48cd930a..980f3951 100644 --- a/src/rabbit_channel_interceptor.erl +++ b/src/rabbit_channel_interceptor.erl @@ -19,6 +19,7 @@ -module(rabbit_channel_interceptor). +-include("rabbit_framing.hrl"). -include("rabbit.hrl"). -export([intercept_method/1]). @@ -50,6 +51,8 @@ behaviour_info(_Other) -> %%---------------------------------------------------------------------------- +intercept_method(#'basic.publish'{} = M) -> + M; intercept_method(M) -> intercept_method(M, select(M)). |