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 | be7748479a93e180511477eec8360dd9c6598276 (patch) | |
| tree | 74770b63bf9cc99eb921b86edf6d62e3bafcb661 | |
| parent | f59e3eb920d82dc52cb3f467dabb2e418bc45f5e (diff) | |
| download | rabbitmq-server-git-be7748479a93e180511477eec8360dd9c6598276.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
| -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 48cd930ad3..980f3951ca 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)). |