Sha256: 9d2cb19d72f8ad756941a73c8241077b53a21096fdc9d78f50e00745dd712355

Contents?: true

Size: 557 Bytes

Versions: 4

Compression:

Stored size: 557 Bytes

Contents

module Cloudist
  autoload :Singleton, 'singleton'
  
  class Messaging
    include Singleton
    
    class << self
      
      def active_queues
        instance.active_queues
      end
      
      def add_queue(queue)
        (instance.active_queues ||= {}).merge!({queue.name.to_s => queue})
        instance.active_queues
      end
      
      def remove_queue(queue_name)
        (instance.active_queues ||= {}).delete(queue_name.to_s)
        instance.active_queues
      end
    end
    
    attr_accessor :active_queues
    
    
    
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
cloudist-0.4.4 lib/cloudist/messaging.rb
cloudist-0.4.3 lib/cloudist/messaging.rb
cloudist-0.4.2 lib/cloudist/messaging.rb
cloudist-0.4.1 lib/cloudist/messaging.rb