Contents

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

15 entries across 15 versions & 1 rubygems

Version	Path
jackhammer-1.5.1	lib/jackhammer/server.rb
jackhammer-1.5.0	lib/jackhammer/server.rb
jackhammer-1.5.0.rc	lib/jackhammer/server.rb
jackhammer-1.4.0	lib/jackhammer/server.rb
jackhammer-1.3.7	lib/jackhammer/server.rb
jackhammer-1.3.6	lib/jackhammer/server.rb
jackhammer-1.3.5	lib/jackhammer/server.rb
jackhammer-1.3.4	lib/jackhammer/server.rb
jackhammer-1.3.3	lib/jackhammer/server.rb
jackhammer-1.3.2	lib/jackhammer/server.rb
jackhammer-1.3.1	lib/jackhammer/server.rb
jackhammer-1.3.0	lib/jackhammer/server.rb
jackhammer-1.2.0	lib/jackhammer/server.rb
jackhammer-1.1.0	lib/jackhammer/server.rb
jackhammer-1.0.0	lib/jackhammer/server.rb