lib/deimos/utils/db_poller.rb in deimos-ruby-1.7.0.pre.beta1 vs lib/deimos/utils/db_poller.rb in deimos-ruby-1.8.0.pre.beta1
- old
+ new
@@ -1,10 +1,10 @@
# frozen_string_literal: true
require 'deimos/poll_info'
-require 'deimos/utils/executor'
-require 'deimos/utils/signal_handler'
+require 'sigurd/executor'
+require 'sigurd/signal_handler'
module Deimos
module Utils
# Class which continually polls the database and sends Kafka messages.
class DbPoller
@@ -20,13 +20,13 @@
end
pollers = Deimos.config.db_poller_objects.map do |poller_config|
self.new(poller_config)
end
- executor = Deimos::Utils::Executor.new(pollers,
- sleep_seconds: 5,
- logger: Deimos.config.logger)
- signal_handler = Deimos::Utils::SignalHandler.new(executor)
+ executor = Sigurd::Executor.new(pollers,
+ sleep_seconds: 5,
+ logger: Deimos.config.logger)
+ signal_handler = Sigurd::SignalHandler.new(executor)
signal_handler.run!
end
# @param config [Deimos::Configuration::ConfigStruct]
def initialize(config)