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)