diff options
| author | Simon MacMullen <simon@babysimon.co.uk> | 2012-11-21 14:52:20 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@babysimon.co.uk> | 2012-11-21 14:52:20 +0000 |
| commit | 156e38650dcd268971b72314ddf3fdff13b2c85f (patch) | |
| tree | 24872f3e78e50ce5cafebdc33201ed6f58b090d7 /src | |
| parent | 9559027eb68041f94f8e1a3021b829f2d7c3ff13 (diff) | |
| download | rabbitmq-server-git-156e38650dcd268971b72314ddf3fdff13b2c85f.tar.gz | |
Carry on if an individual notification fails.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_policy.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_policy.erl b/src/rabbit_policy.erl index 2717cc9217..2c997f16bb 100644 --- a/src/rabbit_policy.erl +++ b/src/rabbit_policy.erl @@ -166,8 +166,8 @@ update_policies(VHost) -> [update_queue(Q, Policies) || Q <- rabbit_amqqueue:list(VHost)]} end), - [notify(X) || X <- Xs], - [notify(Q) || Q <- Qs], + [catch notify(X) || X <- Xs], + [catch notify(Q) || Q <- Qs], ok. update_exchange(X = #exchange{name = XName, policy = OldPolicy}, Policies) -> |