diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-03-28 11:14:58 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-03-28 11:14:58 +0100 |
| commit | 3331680ab15006fd54d03a1d3f0afed4f5f2bcd1 (patch) | |
| tree | cd7db6dd1cc7b55e6383983786f617015571d9f9 /src/rabbit_reader.erl | |
| parent | df68fb98eb95fbc44eaffe4848ecc71810cca82d (diff) | |
| download | rabbitmq-server-3331680ab15006fd54d03a1d3f0afed4f5f2bcd1.tar.gz | |
Alert remote and local alarm subscribers differently
Diffstat (limited to 'src/rabbit_reader.erl')
| -rw-r--r-- | src/rabbit_reader.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 5d08d28c..5e9e78d3 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -25,7 +25,7 @@ -export([init/4, mainloop/2]). --export([conserve_resources/3, server_properties/1]). +-export([conserve_resources/2, server_properties/1]). -define(HANDSHAKE_TIMEOUT, 10). -define(NORMAL_TIMEOUT, 3). @@ -71,7 +71,7 @@ -spec(info/2 :: (pid(), rabbit_types:info_keys()) -> rabbit_types:infos()). -spec(force_event_refresh/1 :: (pid()) -> 'ok'). -spec(shutdown/2 :: (pid(), string()) -> 'ok'). --spec(conserve_resources/3 :: (pid(), atom(), boolean()) -> 'ok'). +-spec(conserve_resources/2 :: (pid(), boolean()) -> 'ok'). -spec(server_properties/1 :: (rabbit_types:protocol()) -> rabbit_framing:amqp_table()). @@ -133,7 +133,7 @@ info(Pid, Items) -> force_event_refresh(Pid) -> gen_server:cast(Pid, force_event_refresh). -conserve_resources(Pid, _Source, Conserve) -> +conserve_resources(Pid, Conserve) -> Pid ! {conserve_resources, Conserve}, ok. |