diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-01-08 16:27:50 +0300 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2021-01-08 07:55:43 -0800 |
| commit | 345e5cf3f8389d81e972fae1fe3b5f0176d9bc94 (patch) | |
| tree | 0a451177b4a0685e9308c174b04a65dc23a067ef | |
| parent | bd29642f04e62360ad2ce72797eaed7db5b4064e (diff) | |
| download | rabbitmq-server-git-rabbitmq-shovel-2655.tar.gz | |
Clean up specs of autodeleted Shovels once every 60 secondsrabbitmq-shovel-2655
| -rw-r--r-- | deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup.erl | 2 | ||||
| -rw-r--r-- | deps/rabbitmq_shovel/src/rabbit_shovel_status.erl | 2 | ||||
| -rw-r--r-- | deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup.erl b/deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup.erl index 8931ad9113..405e385b49 100644 --- a/deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup.erl +++ b/deps/rabbitmq_shovel/src/rabbit_shovel_dyn_worker_sup.erl @@ -20,7 +20,7 @@ start_link(Name, Config) -> ShovelParameter = rabbit_shovel_util:get_shovel_parameter(Name), maybe_start_link(ShovelParameter, Name, Config). -maybe_start_link(not_found, Name, _Config) -> +maybe_start_link(not_found, _Name, _Config) -> %% See rabbitmq/rabbitmq-server#2655. %% All dynamic shovels require that their associated parameter is present. %% If not, this shovel has been deleted and stale child spec information diff --git a/deps/rabbitmq_shovel/src/rabbit_shovel_status.erl b/deps/rabbitmq_shovel/src/rabbit_shovel_status.erl index d2378cdcee..a80b2a974b 100644 --- a/deps/rabbitmq_shovel/src/rabbit_shovel_status.erl +++ b/deps/rabbitmq_shovel/src/rabbit_shovel_status.erl @@ -17,7 +17,7 @@ -define(SERVER, ?MODULE). -define(ETS_NAME, ?MODULE). --define(CHECK_FREQUENCY, 5000). % TODO LRB +-define(CHECK_FREQUENCY, 60000). -record(state, {timer}). -record(entry, {name, type, info, timestamp}). diff --git a/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl b/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl index 9b70135502..1b88262eb0 100644 --- a/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl +++ b/deps/rabbitmq_shovel/src/rabbit_shovel_worker.erl @@ -30,7 +30,7 @@ start_link(Type, Name, Config) -> ShovelParameter = rabbit_shovel_util:get_shovel_parameter(Name), maybe_start_link(ShovelParameter, Type, Name, Config). -maybe_start_link(not_found, dynamic, Name, _Config) -> +maybe_start_link(not_found, dynamic, _Name, _Config) -> %% See rabbitmq/rabbitmq-server#2655. %% All dynamic shovels require that their associated parameter is present. %% If not, this shovel has been deleted and stale child spec information |