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 189
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 194
def execute(message)
  begin
    ::ActiveMessaging::Gateway.dispatch(message)
  ensure
    ::ActiveRecord::Base.clear_active_connections! if defined?(::ActiveRecord)
  end

  poller.executed!(current_actor)
end
logger() click to toggle source
# File lib/activemessaging/threaded_poller.rb, line 204
def logger; ::ActiveMessaging.logger; end

[Validate]

Generated with the Darkfish Rdoc Generator 2.