Sha256: 8b702a17442829849123e818efef5ac4ae449a314c7224f4fa8f55c082079556

Contents?: true

Size: 951 Bytes

Versions: 24

Compression:

Stored size: 951 Bytes

Contents

module AMQP
  module Openable
    VALUES = [:opened, :closed, :opening, :closing].freeze

    class ImproperStatusError < ArgumentError
      def initialize(value)
        super("Value #{value.inspect} isn't permitted. Choose one of: #{AMQP::Openable::VALUES.inspect}")
      end
    end

    attr_reader :status
    def status=(value)
      if VALUES.include?(value)
        @status = value
      else
        raise ImproperStatusError.new(value)
      end
    end

    def opened?
      @status == :opened
    end
    alias open? opened?

    def closed?
      @status == :closed
    end



    def opening?
      @status == :opening
    end

    def closing?
      @status == :closing
    end


    def opened!
      @status = :opened
    end # opened!

    def closed!
      @status = :closed
    end # closed!



    def opening!
      @status = :opening
    end # opening!

    def closing!
      @status = :closing
    end # closing!
  end
end

Version data entries

24 entries across 24 versions & 1 rubygems

Version Path
amqp-1.8.0 lib/amqp/openable.rb
amqp-1.7.0 lib/amqp/openable.rb
amqp-1.6.0 lib/amqp/openable.rb
amqp-1.5.3 lib/amqp/openable.rb
amqp-1.5.2 lib/amqp/openable.rb
amqp-1.5.1 lib/amqp/openable.rb
amqp-1.5.0 lib/amqp/openable.rb
amqp-1.4.2 lib/amqp/openable.rb
amqp-1.4.1 lib/amqp/openable.rb
amqp-1.4.0 lib/amqp/openable.rb
amqp-1.3.0 lib/amqp/openable.rb
amqp-1.2.1 lib/amqp/openable.rb
amqp-1.2.0 lib/amqp/openable.rb
amqp-1.1.8 lib/amqp/openable.rb
amqp-1.1.7 lib/amqp/openable.rb
amqp-1.1.6 lib/amqp/openable.rb
amqp-1.1.5 lib/amqp/openable.rb
amqp-1.1.4 lib/amqp/openable.rb
amqp-1.1.3 lib/amqp/openable.rb
amqp-1.1.2 lib/amqp/openable.rb