diff options
| author | Matthias Radestock <matthias@lshift.net> | 2008-11-20 13:14:39 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2008-11-20 13:14:39 +0000 |
| commit | 644ba5b92961ce48fb227783b4b544690ab411b7 (patch) | |
| tree | 9f58faff835fb7b351c74f5fc6cf6ee3e5f1514a /src | |
| parent | d7fce2536718e7d235297a8f7c81edc88902eea5 (diff) | |
| download | rabbitmq-server-git-644ba5b92961ce48fb227783b4b544690ab411b7.tar.gz | |
disable cross-node routing optimisation
until we figure out how to make it work w/o breaking the effect
visibility guarantee
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_router.erl | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index a233764766..54279d024e 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -52,6 +52,12 @@ start_link() -> gen_server:start_link({local, ?SERVER}, ?MODULE, [], []). deliver(QPids, Mandatory, Immediate, Txn, Message) -> + %% cross-node routing optimisation is disabled because of bug 19758. + fun deliver_optimised/5, %% prevents "function ... unused" warnings + check_delivery(Mandatory, Immediate, + run_bindings(QPids, Mandatory, Immediate, Txn, Message)). + +deliver_optimised(QPids, Mandatory, Immediate, Txn, Message) -> %% we reduce inter-node traffic by grouping the qpids by node and %% only delivering one copy of the message to each node involved, %% which then in turn delivers it to its queues. |