class Jackhammer::Server

Public Class Methods

configure() { |config| ... } click to toggle source
# File lib/jackhammer/server.rb, line 3
def self.configure
  Jackhammer.configure do |config|
    yield config
    config.server = self
  end
end
start() click to toggle source
# File lib/jackhammer/server.rb, line 10
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