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