diff --git a/app/models/transport.rb b/app/models/transport.rb index 058980926..bfecdda90 100644 --- a/app/models/transport.rb +++ b/app/models/transport.rb @@ -48,6 +48,13 @@ class Transport .bind("amq.topic", routing_key: "bot.*.resources_v0.#") end + def ping_channel + @resource_channel ||= self.connection + .create_channel + .queue("resource_workers") + .bind("amq.topic", routing_key: "bot.*.ping.#") + end + def amqp_topic @amqp_topic ||= self .connection diff --git a/lib/rabbit_workers.rb b/lib/rabbit_workers.rb index 27da281ce..c11a1ce02 100644 --- a/lib/rabbit_workers.rb +++ b/lib/rabbit_workers.rb @@ -10,10 +10,20 @@ require_relative "../app/lib/service_runner_base.rb" require_relative "../app/lib/service_runner_base.rb" class RabbitWorker + class FakePing + def self.process(info, payl) + puts "=====================================" + puts info + puts payl + puts "=====================================" + end + end + WAIT = 3 SERVICES = { log_channel: LogService, - resource_channel: Resources::Service + resource_channel: Resources::Service, + ping_channel: FakePing } def run_it!(chan, service) diff --git a/package.json b/package.json index 6af5f1164..17dbce691 100644 --- a/package.json +++ b/package.json @@ -43,7 +43,7 @@ "coveralls": "3.0.3", "enzyme": "3.9.0", "enzyme-adapter-react-16": "1.13.0", - "farmbot": "github:RickCarlino/farmbot-js", + "farmbot": "8.0.0-rc4", "farmbot-toastr": "1.0.3", "i18next": "15.1.1", "jest": "24.8.0",