class LavinMQ::Client::Channel
- LavinMQ::Client::Channel
- Reference
- Object
Included Modules
Defined in:
lavinmq/client/channel.crlavinmq/client/channel/consumer.cr
Constructors
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)
- #basic_return(msg : Message, mandatory : Bool, immediate : Bool)
- #cancel_consumer(frame)
- #close
- #confirm_ack(multiple = false)
- #confirm_count : UInt64
- #confirm_nack(multiple = false)
- #confirm_select(frame)
- #consume(frame)
- #consumers : Array(LavinMQ::Client::Channel::Consumer)
- #deliver(frame, msg, redelivered = false) : Nil
- #deliver_count : UInt64
- #details_tuple
- #each_unacked(&)
- #flow(active : Bool)
- #flow? : Bool
- #get_count : UInt64
- #global_prefetch_count : UInt16
- #has_capacity : Channel(Bool)
- #has_capacity?
- #id : UInt16
- #log : Log
- #name : String
- #next_delivery_tag(queue : Queue, sp, persistent, no_ack, consumer) : UInt64
- #next_msg_headers(frame)
- #prefetch_count : 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_count
- #unacked_for_queue(queue) : Iterator(SegmentPosition)
- #update_rates