Contents

#!/usr/bin/env ruby
require 'rubygems'
require 'etc'
require 'yaml'
require 'daemons/daemonize'
require 'stomp_server_ng'
require 'optparse'
require 'logger'

$STOMP_SERVER = true

$HTTP_ENABLE = false
if $HTTP_ENABLE
  require 'mongrel'
  require 'stomp_server/protocols/http'
end
#
# Use epoll if available.
#
EventMachine::epoll
#
# Run.
#
EventMachine::run do

  ## Get the configuration and initialize the stomp engine
  config = StompServer::Configurator.new
  stomp = StompServer::Run.new(config.opts)
  stomp.start

  log = Logger.new(STDOUT)
  log.level = Logger::DEBUG

  # Might want to uncomment this if you are sending large files
  #EventMachine::add_periodic_timer 10, proc {GC.start}
  
  log.debug "Client authorization enabled" if config.opts[:auth]

  ## Start protocol handlers

  log.debug "Stomp protocol handler starting on #{config.opts[:host]} port #{config.opts[:port]}"
  EventMachine.start_server(config.opts[:host], 
      config.opts[:port], 
      StompServer::Protocols::Stomp, 
        stomp.auth_required,    # *args: arg[0] 
        stomp.queue_manager,    # *args: arg[1] 
        stomp.topic_manager,    # *args: arg[2] 
        stomp.stompauth,        # *args: arg[3] 
        config.opts             # Options hash
      )

  # TODO: any http testing and protocol handler changes required.
  if $HTTP_ENABLE
    log.debug "Http protocol handler starting on #{config.opts[:host]} port 8080"
    EventMachine.start_server(config.opts[:host], 8080, StompServer::Protocols::Http) {|s| s.instance_eval {
        @@auth_required=stomp.auth_required
        @@queue_manager=stomp.queue_manager
        @@topic_manager=stomp.topic_manager
        @@stompauth = stomp.stompauth
      }
    }
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
stompserver_ng-1.0.6	bin/stompserver_ng