Contents

module ResqueBus
  # publishes on a delay
  class Publisher
    class << self
      def perform(event_type, attributes = {})
        attributes["bus_event_type"] = event_type # now using one hash only
        ResqueBus.note_deprecation "[MIGRATION] Note: new events will be using QueueBus::Publisher"
        ::QueueBus::Publisher.perform(attributes)
      end
    end

  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
resque-bus-0.7.0	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.6.1	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.6.0	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.5.12	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.5.11	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.5.10	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.5.9	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.5.8	lib/resque_bus/compatibility/publisher.rb
resque-bus-0.5.7	lib/resque_bus/compatibility/publisher.rb