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.1.1	lib/amqp/openable.rb
amqp-1.1.0	lib/amqp/openable.rb
amqp-1.1.0.rc1	lib/amqp/openable.rb
amqp-1.1.0.pre2	lib/amqp/openable.rb