class LavinMQ::Client::Channel

Included Modules

Defined in:

lavinmq/client/channel.cr
lavinmq/client/channel/consumer.cr
lavinmq/client/channel/stream_consumer.cr

Constant Summary

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

Constructors

Instance Method Summary

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, to_json(json : JSON::Builder) to_json

Macros inherited from module LavinMQ::Stats

rate_stats(stats_keys, log_keys = [] of ::String) rate_stats

Constructor Detail

def self.new(client : Client, id : UInt16) #

[View source]

Instance Method Detail

def ack_count : UInt64 #

def add_content(frame) #

[View source]
def basic_ack(frame) #

[View source]
def basic_get(frame) #

[View source]
def basic_nack(frame) #

[View source]
def basic_qos(frame) : Nil #

[View source]
def basic_recover(frame) : Nil #

[View source]
def basic_reject(frame) #

[View source]
def cancel_consumer(frame) #

[View source]
def check_consumer_timeout #

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


[View source]
def close #

[View source]
def confirm_count : UInt64 #

def confirm_select(frame) #

[View source]
def consume(frame) #

[View source]

[View source]
def current_stats_details #

Like stats_details but without log


[View source]
def deliver(frame, msg, redelivered = false) : Nil #

[View source]
def deliver_count : UInt64 #

def details_tuple #

[View source]
def flow(active : Bool) #

[View source]
def flow? : Bool #

[View source]
def get_count : UInt64 #

def global_prefetch_count : UInt16 #

[View source]
def has_capacity : Channel(Nil) #

[View source]
def has_capacity? : Bool #

[View source]
def id : UInt16 #

[View source]
def name : String #

[View source]
def next_msg_headers(frame) #

[View source]
def prefetch_count : UInt16 #

[View source]
def publish_count : UInt64 #

def redeliver_count : UInt64 #

def reject_count : UInt64 #

def return_unroutable_count : UInt64 #

def running=(running : Bool) #

[View source]
def running? : Bool #

[View source]
def send(frame) #

[View source]
def start_publish(frame) #

[View source]
def state #

[View source]
def stats_details #

[View source]
def tx_commit(frame) #

[View source]
def tx_rollback(frame) #

[View source]
def tx_select(frame) #

[View source]

[View source]
def unacked_count #

[View source]
def update_rates : Nil #

[View source]