Contents

module ResqueBus
  # publishes on a delay
  class Publisher
    def self.perform(event_type, attributes = {})
      ResqueBus.log_worker("Publisher running: #{event_type} - #{attributes.inspect}")
      ResqueBus.publish(event_type, attributes)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
resque-bus-0.2.4	lib/resque_bus/publisher.rb
resque-bus-0.2.3	lib/resque_bus/publisher.rb