Contents

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

  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
resque-bus-0.3.7	lib/resque_bus/publisher.rb
resque-bus-0.3.6	lib/resque_bus/publisher.rb
resque-bus-0.3.5	lib/resque_bus/publisher.rb
resque-bus-0.3.4	lib/resque_bus/publisher.rb
resque-bus-0.3.3	lib/resque_bus/publisher.rb
resque-bus-0.3.2	lib/resque_bus/publisher.rb
resque-bus-0.3.1	lib/resque_bus/publisher.rb
resque-bus-0.3.0	lib/resque_bus/publisher.rb
resque-bus-0.2.10	lib/resque_bus/publisher.rb
resque-bus-0.2.9	lib/resque_bus/publisher.rb
resque-bus-0.2.8	lib/resque_bus/publisher.rb
resque-bus-0.2.7	lib/resque_bus/publisher.rb
resque-bus-0.2.6	lib/resque_bus/publisher.rb
resque-bus-0.2.5	lib/resque_bus/publisher.rb