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 | 567c69fb37cc569107b8e779d43d01d929772e5d (patch) | |
| tree | a7fd4dbf9e8e256c6de21ba830ce7254264c1ec3 /src | |
| parent | d0b37974ecbad5d7286b16212a48c2339121ce1e (diff) | |
| download | rabbitmq-server-git-567c69fb37cc569107b8e779d43d01d929772e5d.tar.gz | |
refactor: simplify rabbit_exchange:serialise_events
Diffstat (limited to 'src')
| -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 f209b3ca20..e72cbafef7 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 |