diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-21 15:47:05 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-11-21 15:47:05 +0000 |
| commit | 45c6dc9aba6266ac2c39f86ca45bf07b44e50805 (patch) | |
| tree | a7fd4dbf9e8e256c6de21ba830ce7254264c1ec3 | |
| parent | 5d308a066213334a009ae2edbb980e974279c9bd (diff) | |
| download | rabbitmq-server-45c6dc9aba6266ac2c39f86ca45bf07b44e50805.tar.gz | |
refactor: simplify rabbit_exchange:serialise_events
| -rw-r--r-- | src/rabbit_exchange.erl | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index f209b3ca..e72cbafe 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -124,12 +124,8 @@ callback(X = #exchange{type = XType}, Fun, Serial0, Args) -> policy_changed(X1, X2) -> callback(X1, policy_changed, none, [X1, X2]). serialise_events(X = #exchange{type = Type}) -> - case [Serialise || M <- decorators(), - Serialise <- [M:serialise_events(X)], - Serialise == true] of - [] -> (type_to_module(Type)):serialise_events(); - _ -> true - end. + lists:any(fun (M) -> M:serialise_events(X) end, decorators()) + orelse (type_to_module(Type)):serialise_events(). serial(#exchange{name = XName} = X) -> Serial = case serialise_events(X) of |