Contents

module Eventboss
  class Runner
    class << self
      def launch
        queues = Eventboss::QueueListener.list
        client = Eventboss.configuration.sqs_client
        config = Eventboss.configuration

        Eventboss::Instrumentation.add(queues)

        launcher = Launcher.new(queues, client, worker_count: config.concurrency)

        self_read, _self_write = IO.pipe
        begin
          launcher.start
          while (_readable_io = IO.select([self_read]))
            # handle_signal(readable_io.first[0].gets.strip)
          end
        rescue Interrupt
          launcher.stop
          exit 0
        end
      end

      def start
        configuration = Eventboss.configuration

        queue_listeners = Eventboss::QueueListener.list
        Eventboss::Instrumentation.add(queue_listeners)
        polling_strategy = configuration.polling_strategy.call(queue_listeners.keys)

        fetcher = Eventboss::Fetcher.new(configuration)
        executor = Concurrent.global_io_executor

        manager = Eventboss::Manager.new(
          fetcher,
          polling_strategy,
          executor,
          queue_listeners,
          configuration.concurrency,
          configuration.error_handlers
        )

        manager.start

        self_read, self_write = IO.pipe
        begin
          while (readable_io = IO.select([self_read]))
            signal = readable_io.first[0].gets.strip
            # handle_signal(signal)
          end
        rescue Interrupt
          executor.shutdown
          executor.wait_for_termination
          exit 0
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
eventboss-1.0.6	lib/eventboss/runner.rb
eventboss-1.0.5	lib/eventboss/runner.rb
eventboss-1.0.4	lib/eventboss/runner.rb
eventboss-1.0.3	lib/eventboss/runner.rb
eventboss-1.0.2	lib/eventboss/runner.rb
eventboss-1.0.1	lib/eventboss/runner.rb
eventboss-1.0.0	lib/eventboss/runner.rb