Contents

# frozen_string_literal: true

module QueueBus
  # A simple publishing worker for QueueBus. Makes publishing asynchronously possible since
  # it may be enqueued to the background worker with a delay. This will allow the event to
  # be published at a later time.
  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

8 entries across 8 versions & 1 rubygems

Version	Path
queue-bus-0.13.3	lib/queue_bus/publisher.rb
queue-bus-0.13.2	lib/queue_bus/publisher.rb
queue-bus-0.13.1	lib/queue_bus/publisher.rb
queue-bus-0.13.0	lib/queue_bus/publisher.rb
queue-bus-0.12.0	lib/queue_bus/publisher.rb
queue-bus-0.11.0	lib/queue_bus/publisher.rb
queue-bus-0.10.0	lib/queue_bus/publisher.rb
queue-bus-0.9.1	lib/queue_bus/publisher.rb