Contents

begin
  require 'em-jack'
rescue LoadError
  STDERR.puts "You need the 'em-jack' gem if you want to use Beanstalkd provider."
end

module Hoth
  module Providers

    class BeanstalkdProvider
      
      attr_reader :module_name, :services_to_listen_for
      
      def initialize(module_name = nil)
        raise ArgumentError.new("You have to specify the module name for the beanstalkd provider") unless module_name
        @module_name = module_name
        identify_services_to_listen_for
      end

      def listen
        EM.run {
          self.services_to_listen_for.each do |service|
            conn_for_service = EMJack::Connection.new(:host => service.endpoint.host, :port => service.endpoint.port)
            conn_for_service.watch(service.transport.tube_name)
            conn_for_service.each_job do |job|
              responsible_service = ServiceRegistry.locate_service(service.name)

              raise ServiceNotFoundException.new("The requested service '#{service.name}' was not found!") if responsible_service.nil?

              begin
                decoded_params = responsible_service.transport.encoder.decode(job.body)
                Hoth::Logger.debug "decoded_params: #{decoded_params}"
                Hoth::Services.send(service.name, *decoded_params)
              rescue => e
                Hoth::Logger.warn "An error occured while invoking the service: #{e.message}"
              ensure
                conn_for_service.delete(job)
              end
            end
          end
        } 
      end
      
      private
        
        def identify_services_to_listen_for
          @services_to_listen_for = Hoth::Modules.service_modules[self.module_name.to_sym].registered_services.select do |service|
              service.endpoint.transport == :beanstalkd
          end
        end

    end
    
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
hoth-0.4.2	lib/hoth/providers/beanstalkd_provider.rb
hoth-0.4.1	lib/hoth/providers/beanstalkd_provider.rb
hoth-0.4.0	lib/hoth/providers/beanstalkd_provider.rb
hoth-0.3.4	lib/hoth/providers/beanstalkd_provider.rb
hoth-0.3.3	lib/hoth/providers/beanstalkd_provider.rb