Sha256: 83e432428dd9a0ad6ff36f32ac64e702dcf5456f534fc59da3a958322aeae7fe

Contents?: true

Size: 517 Bytes

Versions: 1

Compression:

Stored size: 517 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

1 entries across 1 versions & 1 rubygems

Version Path
cloudist-0.5.0 lib/cloudist/messaging.rb