Contents

module Shoryuken
  class Client
    @@queues = {}

    class << self
      def queues(name)
        @@queues[name.to_s] ||= Shoryuken::Queue.new(sqs, name)
      end

      def sqs
        Shoryuken.sqs_client
      end

      def sqs=(sqs)
        # Since the @@queues values (Shoryuken::Queue objects) are built referencing @@sqs, if it changes, we need to
        #   re-build them on subsequent calls to `.queues(name)`.
        @@queues = {}

        Shoryuken.sqs_client = sqs
      end
    end
  end
end

Version data entries

30 entries across 30 versions & 1 rubygems

Version	Path
shoryuken-6.2.1	lib/shoryuken/client.rb
shoryuken-6.2.0	lib/shoryuken/client.rb
shoryuken-6.1.1	lib/shoryuken/client.rb
shoryuken-6.1.0	lib/shoryuken/client.rb
shoryuken-6.0.0	lib/shoryuken/client.rb
shoryuken-5.3.2	lib/shoryuken/client.rb
shoryuken-5.3.1	lib/shoryuken/client.rb
shoryuken-5.3.0	lib/shoryuken/client.rb
shoryuken-5.2.3	lib/shoryuken/client.rb
shoryuken-5.2.2	lib/shoryuken/client.rb
shoryuken-5.2.1	lib/shoryuken/client.rb
shoryuken-5.2.0	lib/shoryuken/client.rb
shoryuken-5.1.1	lib/shoryuken/client.rb
shoryuken-5.1.0	lib/shoryuken/client.rb
shoryuken-5.0.6	lib/shoryuken/client.rb
shoryuken-5.0.5	lib/shoryuken/client.rb
shoryuken-5.0.4	lib/shoryuken/client.rb
shoryuken-5.0.3	lib/shoryuken/client.rb
shoryuken-5.0.2	lib/shoryuken/client.rb
shoryuken-5.0.1	lib/shoryuken/client.rb