diff options
| author | Tim Watson <tim@rabbitmq.com> | 2014-01-28 16:37:58 +0000 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2014-01-28 16:37:58 +0000 |
| commit | 53bec884155eae0b2947338a52f4c1805fa39cc6 (patch) | |
| tree | 0d95f6556dbc5b8d81106eb12d2902bd83956f63 | |
| parent | 656e2861dc19fe0649145598a229ca3d9ee22d62 (diff) | |
| download | rabbitmq-server-git-53bec884155eae0b2947338a52f4c1805fa39cc6.tar.gz | |
Use gs2:mcall/1 in r_amqqueue:force_event_refresh/1
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index eeb0e0bf03..346d57a8e6 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -506,8 +506,8 @@ force_event_refresh() -> force_event_refresh([Q#amqqueue.name || Q <- list()]). force_event_refresh(QNames) -> Qs = [Q || Q <- list(), lists:member(Q#amqqueue.name, QNames)], - {_, Bad} = rabbit_misc:multi_call( - [Q#amqqueue.pid || Q <- Qs], force_event_refresh), + {_, Bad} = gen_server2:mcall( + [{Q#amqqueue.pid, force_event_refresh} || Q <- Qs]), FailedPids = [Pid || {Pid, _Reason} <- Bad], Failed = [Name || #amqqueue{name = Name, pid = Pid} <- Qs, lists:member(Pid, FailedPids)], |