diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-02-10 11:01:34 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-02-10 11:01:34 +0000 |
| commit | 7f750a915d224aecd8f156be0a9aac2c2a5b4550 (patch) | |
| tree | 971a52826418a34e6a12e31a1e1497e5753b4542 /src/rabbit_direct.erl | |
| parent | 95173fe26aeb4e18653d751ecf9a99e170b20986 (diff) | |
| download | rabbitmq-server-7f750a915d224aecd8f156be0a9aac2c2a5b4550.tar.gz | |
Include a reference in forced event refreshes.
Diffstat (limited to 'src/rabbit_direct.erl')
| -rw-r--r-- | src/rabbit_direct.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_direct.erl b/src/rabbit_direct.erl index 5a004792..e6e4b4cc 100644 --- a/src/rabbit_direct.erl +++ b/src/rabbit_direct.erl @@ -16,7 +16,7 @@ -module(rabbit_direct). --export([boot/0, force_event_refresh/0, list/0, connect/5, +-export([boot/0, force_event_refresh/1, list/0, connect/5, start_channel/9, disconnect/2]). %% Internal -export([list_local/0]). @@ -28,7 +28,7 @@ -ifdef(use_specs). -spec(boot/0 :: () -> 'ok'). --spec(force_event_refresh/0 :: () -> 'ok'). +-spec(force_event_refresh/1 :: (reference()) -> 'ok'). -spec(list/0 :: () -> [pid()]). -spec(list_local/0 :: () -> [pid()]). -spec(connect/5 :: ((rabbit_types:username() | rabbit_types:user() | @@ -54,8 +54,8 @@ boot() -> rabbit_sup:start_supervisor_child( [{local, rabbit_direct_client_sup}, {rabbit_channel_sup, start_link, []}]). -force_event_refresh() -> - [Pid ! force_event_refresh || Pid<- list()], +force_event_refresh(Ref) -> + [Pid ! {force_event_refresh, Ref} || Pid <- list()], ok. list_local() -> |