diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-08-05 17:15:08 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-08-05 17:15:08 +0100 |
| commit | b73d562111cd764097cde55ff761e3c2a2d82ec0 (patch) | |
| tree | 3108af27d17c0f07ab7c0ace5370eecf48f67f0e /src/rabbit_amqqueue.erl | |
| parent | 51c8e02239abcb2f8a9a80db8ed2385e0ce67d10 (diff) | |
| parent | b18de45aaea54480827f593e1caced01c89d7e73 (diff) | |
| download | rabbitmq-server-b73d562111cd764097cde55ff761e3c2a2d82ec0.tar.gz | |
Merge in default
Diffstat (limited to 'src/rabbit_amqqueue.erl')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index a7c92e51..0aa8921f 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -22,6 +22,7 @@ check_exclusive_access/2, with_exclusive_access_or_die/3, stat/1, deliver/2, requeue/3, ack/3, reject/4]). -export([list/1, info_keys/0, info/1, info/2, info_all/1, info_all/2]). +-export([force_event_refresh/0]). -export([consumers/1, consumers_all/1, consumer_info_keys/0]). -export([basic_get/3, basic_consume/7, basic_cancel/4]). -export([notify_sent/2, unblock/2, flush_all/2]). @@ -88,6 +89,7 @@ -spec(info_all/1 :: (rabbit_types:vhost()) -> [rabbit_types:infos()]). -spec(info_all/2 :: (rabbit_types:vhost(), rabbit_types:info_keys()) -> [rabbit_types:infos()]). +-spec(force_event_refresh/0 :: () -> 'ok'). -spec(consumers/1 :: (rabbit_types:amqqueue()) -> [{pid(), rabbit_types:ctag(), boolean()}]). @@ -381,6 +383,11 @@ info_all(VHostPath) -> map(VHostPath, fun (Q) -> info(Q) end). info_all(VHostPath, Items) -> map(VHostPath, fun (Q) -> info(Q, Items) end). +force_event_refresh() -> + [map(VHost, fun(Q) -> delegate_cast(Q#amqqueue.pid, + force_event_refresh) end) || + VHost <- rabbit_vhost:list()]. + consumers(#amqqueue{ pid = QPid }) -> delegate_call(QPid, consumers). |