Contents

module QueueBus
  # publishes on a delay
  class Publisher

    class << self
      def perform(attributes)
        event_type = attributes["bus_event_type"]
        ::QueueBus.log_worker("Publisher running: #{event_type} - #{attributes.inspect}")
        ::QueueBus.publish(event_type, attributes)
      end
    end

  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
queue-bus-0.9.0	lib/queue_bus/publisher.rb
queue-bus-0.8.1	lib/queue_bus/publisher.rb
queue-bus-0.8.0	lib/queue_bus/publisher.rb
queue-bus-0.7.0	lib/queue_bus/publisher.rb
queue-bus-0.6.0	lib/queue_bus/publisher.rb
queue-bus-0.5.9	lib/queue_bus/publisher.rb
queue-bus-0.5.8	lib/queue_bus/publisher.rb
queue-bus-0.5.7	lib/queue_bus/publisher.rb
queue-bus-0.5.6	lib/queue_bus/publisher.rb
queue-bus-0.5.5	lib/queue_bus/publisher.rb
queue-bus-0.5.4	lib/queue_bus/publisher.rb
queue-bus-0.5.3	lib/queue_bus/publisher.rb