class LavinMQ::Client::Channel
- LavinMQ::Client::Channel
- Reference
- Object
Included Modules
Defined in:
lavinmq/client/channel.crlavinmq/client/channel/consumer.cr
lavinmq/client/channel/stream_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)
- #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
- #details_tuple
- #flow(active : Bool)
- #flow? : Bool
- #get_count : UInt64
- #global_prefetch_count : UInt16
- #has_capacity : Channel(Nil)
- #has_capacity? : Bool
- #id : UInt16
- #log : Log
- #name : String
- #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
- #update_rates : Nil
Instance methods inherited from module LavinMQ::SortableJSON
details_tuple
details_tuple,
to_json(json : JSON::Builder)
to_json
Constructor Detail
Instance Method Detail
def check_consumer_timeout
#
Iterate over all unacked messages and see if any has been unacked longer than the queue's consumer timeout