class AvalancheMQ::Queue

• AvalancheMQ::Queue
• Reference
• Object

Included Modules

• AvalancheMQ::PolicyTarget
• AvalancheMQ::SortableJSON
• AvalancheMQ::Stats
• Observable

Direct Known Subclasses

• AvalancheMQ::DelayedExchangeQueue
• AvalancheMQ::DurableQueue
• AvalancheMQ::PriorityQueue

Defined in:

Constructors

• .new(vhost : VHost, name : String, exclusive : Bool = false, auto_delete : Bool = false, arguments : Hash(String, AMQ::Protocol::Field) = Hash(String, AMQP::Field).new)

Class Method Summary

• .generate_name

Instance Method Summary

• #ack(sp : SegmentPosition, persistent : Bool) : Nil
• #ack_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #add_consumer(consumer : Client::Channel::Consumer)
• #any? : Bool
• #apply_policy(policy : Policy)
• #arguments : Hash(String, AMQ::Protocol::Field)
• #auto_delete : Bool
• #basic_get(no_ack) : Envelope | Nil
• #clear_policy
• #close : Bool
• #closed? : Bool?
• #compact
• #confirm_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #consumer_available
• #consumer_count
• #consumers : AvalancheMQ::ConsumerStore
• #delete : Bool
• #deliver_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #details_tuple
• #durable : Bool
• #empty? : Bool
• #exclusive : Bool
• #flow=(flow : Bool)
• #fsync_ack
• #fsync_enq
• #get_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #get_no_ack_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #has_exclusive_consumer? : Bool
• #immediate_delivery?
• #in_use?
• #inspect(io : IO)

  Appends a String representation of this object which includes its class name, its object address and the values of all instance variables.

• #internal=(internal : Bool)
• #internal? : Bool
• #last_get_time : Time::Span
• #match?(durable, exclusive, auto_delete, arguments)
• #match?(frame)
• #message_available
• #message_count
• #message_count_log : Deque(UInt32)

  Creates @[x]_count and @[x]_rate and @[y]_log

• #metadata(sp) : MessageMetadata | Nil
• #name : String
• #pause!
• #policy : Policy | Nil
• #publish(sp : SegmentPosition, persistent = false) : Bool
• #publish_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #purge : UInt32
• #read(sp : SegmentPosition)
• #ready : AvalancheMQ::Queue::ReadyQueue
• #redeclare
• #redeliver_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #refresh_ttl_timeout
• #reject(sp : SegmentPosition, requeue : Bool)
• #reject_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #resume!
• #return_unroutable_count : UInt64

  Creates @[x]_count and @[x]_rate and @[y]_log

• #rm_consumer(consumer : Client::Channel::Consumer, basic_cancel = false)
• #state : AvalancheMQ::QueueState
• #stats_details

  Creates @[x]_count and @[x]_rate and @[y]_log

• #to_json(builder : JSON::Builder)
• #unacked : AvalancheMQ::Queue::UnackQueue
• #unacked_count
• #unacked_count_log : Deque(UInt32)

  Creates @[x]_count and @[x]_rate and @[y]_log

• #update_rates

  Creates @[x]_count and @[x]_rate and @[y]_log

• #vhost : AvalancheMQ::VHost

Constructor Detail

Class Method Detail

Instance Method Detail

class Person
  def initialize(@name : String, @age : Int32)
  end
end

Person.new("John", 32).inspect # => #<Person:0x10fd31f20 @name="John", @age=32>