class LavinMQ::AMQP::Channel

• LavinMQ::AMQP::Channel
• LavinMQ::Client::Channel
• Reference
• Object

Included Modules

• LavinMQ::SortableJSON
• LavinMQ::Stats

Defined in:

lavinmq/amqp/channel.cr

Constant Summary

Log = LavinMQ::Log.for("amqp.channel")

Constructors

• .new(client : Client, id : UInt16)

Instance Method Summary

• #ack_count : UInt64
• #add_content(frame)
• #basic_ack(frame)
• #basic_get(frame)
• #basic_nack(frame)
• #basic_qos(frame) : Nil
• #basic_recover(frame) : Nil
• #basic_reject(frame)
• #cancel_consumer(frame)
• #check_consumer_timeout

  Iterate over all unacked messages and see if any has been unacked longer than the queue's consumer timeout

• #close
• #confirm_count : UInt64
• #confirm_select(frame)
• #consume(frame)
• #consumers : Array(LavinMQ::Client::Channel::Consumer)
• #current_stats_details

  Like stats_details but without log

• #deliver(frame, msg, redelivered = false) : Nil
• #deliver_count : UInt64
• #deliver_get_count : UInt64
• #details_tuple
• #flow(active : Bool)
• #flow? : Bool
• #get_count : UInt64
• #global_prefetch_count : UInt16
• #has_capacity : Channel(Nil)
• #has_capacity? : Bool
• #id : UInt16
• #name : String
• #next_msg_headers(frame)
• #prefetch_count : UInt16
• #prefetch_count=(value : UInt16)
• #publish_count : UInt64
• #redeliver_count : UInt64
• #reject_count : UInt64
• #return_unroutable_count : UInt64
• #running=(running : Bool)
• #running? : Bool
• #send(frame)
• #start_publish(frame)
• #state
• #stats_details
• #tx_commit(frame)
• #tx_rollback(frame)
• #tx_select(frame)
• #unacked : Deque(LavinMQ::AMQP::Channel::Unack)
• #unacked_count
• #update_rates : Nil

Constructor Detail

Instance Method Detail