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 | c0524468b1feb9ff7348c8c73d480c2bec875112 (patch) | |
| tree | 24872f3e78e50ce5cafebdc33201ed6f58b090d7 | |
| parent | b7c18bef2f95c242865f21a43d912a02d0a51ecd (diff) | |
| download | rabbitmq-server-c0524468b1feb9ff7348c8c73d480c2bec875112.tar.gz | |
Carry on if an individual notification fails.
| -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 2717cc92..2c997f16 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) -> |