Contents

# frozen_string_literal: true

module Jackhammer
  class Server
    def self.configure
      Jackhammer.configure do |config|
        yield config
        config.server = self
      end
    end

    def self.start
      running = true
      Signal.trap('INT') do
        print "\n\nstopping...\n"
        running = false
      end
      Jackhammer.topics.each { |_name, topic| topic.subscribe_queues }
      Log.info 'Topic queues subscribed and listening... Send INT signal to stop.'
      sleep 2 while running
      Jackhammer.connection.close
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
jackhammer-0.2.3	lib/jackhammer/server.rb
jackhammer-0.2.2	lib/jackhammer/server.rb
jackhammer-0.2.1	lib/jackhammer/server.rb
jackhammer-0.2.0	lib/jackhammer/server.rb
jackhammer-0.1.1	lib/jackhammer/server.rb