Contents

module Shoryuken
  class Client
    @@queues = {}
    @@topics = {}

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

      def sns
        @sns ||= Shoryuken::AwsConfig.sns
      end

      def sns_arn
        @sns_arn ||= SnsArn
      end

      def sqs
        @sqs ||= Shoryuken::AwsConfig.sqs
      end

      def topics(name)
        @@topics[name.to_s] ||= Topic.new(name, sns)
      end

      attr_accessor :account_id
      attr_writer :sns, :sqs, :sqs_resource, :sns_arn
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
shoryuken-2.1.3	lib/shoryuken/client.rb
shoryuken-2.1.2	lib/shoryuken/client.rb
shoryuken-2.1.1	lib/shoryuken/client.rb
shoryuken-2.1.0	lib/shoryuken/client.rb