Sha256: 08bfb547b2aa1531a1f08e0b85fed54a4bc263664c06302cdb592a6d5edc9348

Contents?: true

Size: 369 Bytes

Versions: 10

Compression:

Stored size: 369 Bytes

Contents

module Eventboss
  class QueueListener
    class << self
      def list
        Hash[Eventboss::Listener::ACTIVE_LISTENERS.map do |src_app_event, listener|
          [Eventboss::Queue.new("#{Eventboss.configuration.eventboss_app_name}-#{Eventboss.configuration.sns_sqs_name_infix}-#{src_app_event}-#{Eventboss.env}"), listener]
        end]
      end
    end
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
eventboss-1.2.0 lib/eventboss/queue_listener.rb
eventboss-1.1.3 lib/eventboss/queue_listener.rb
eventboss-1.1.2 lib/eventboss/queue_listener.rb
eventboss-1.1.1 lib/eventboss/queue_listener.rb
eventboss-1.1.0 lib/eventboss/queue_listener.rb
eventboss-1.0.6 lib/eventboss/queue_listener.rb
eventboss-1.0.5 lib/eventboss/queue_listener.rb
eventboss-1.0.4 lib/eventboss/queue_listener.rb
eventboss-1.0.3 lib/eventboss/queue_listener.rb
eventboss-1.0.2 lib/eventboss/queue_listener.rb