Parent

Included Modules

Files

Class/Module Index [+]

Quicksearch

ActiveMessaging::Worker

Attributes

options[RW]
poller[RW]

Public Class Methods

new(poller, options) click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 203
def initialize(poller, options)
  self.poller = poller
  self.options = options
end

Public Instance Methods

execute(message) click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 208
def execute(message)
  begin
    ::ActiveMessaging::Gateway.dispatch(message)
  rescue Object => err
    logger.error("ActiveMessaging::Worker.execute error - #{err.inspect}")
    abort(err)
  ensure
    ::ActiveRecord::Base.clear_active_connections! if defined?(::ActiveRecord)
  end

  poller.executed!(current_actor)
end
inspect() click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 221
def inspect
  "#<Worker #{to_s}>"
end
logger() click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 229
def logger; ::ActiveMessaging.logger; end
to_s() click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 225
def to_s
  @str ||= "#{Process.pid}-#{Thread.current.object_id}:#{self.object_id}"
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.