Contents

module Rpush
  module Daemon
    module ServiceConfigMethods
      DISPATCHERS = {
        :http => Rpush::Daemon::Dispatcher::Http,
        :tcp => Rpush::Daemon::Dispatcher::Tcp
      }

      def dispatcher(name = nil, options = {})
        @dispatcher_name = name
        @dispatcher_options = options
      end

      def dispatcher_class
        DISPATCHERS[@dispatcher_name] || (raise NotImplementedError)
      end

      def delivery_class
        const_get('Delivery')
      end

      def new_dispatcher(app)
        dispatcher_class.new(app, delivery_class, @dispatcher_options)
      end

      def loops(*loops)
        @loops ||= []
        @loops = loops if loops.any?
        @loops
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rpush-1.0.0-java	lib/rpush/daemon/service_config_methods.rb
rpush-1.0.0	lib/rpush/daemon/service_config_methods.rb