class AvalancheMQ::Client::Channel
- AvalancheMQ::Client::Channel
- Reference
- Object
Included Modules
Defined in:
avalanchemq/client/channel.cravalanchemq/client/channel/consumer.cr
Constant Summary
-
DIRECT_REPLY_PREFIX =
"amq.direct.reply-to" -
MAX_MESSAGE_BODY_SIZE =
(512 * 1024) * 1024
Constructors
Instance Method Summary
- #ack_count : UInt64
- #add_content(frame, ts)
- #basic_ack(frame)
- #basic_get(frame)
- #basic_nack(frame)
- #basic_qos(frame) : Nil
- #basic_recover(frame) : Nil
- #basic_reject(frame)
- #basic_return(msg)
- #cancel_consumer(frame)
- #client : AvalancheMQ::Client
- #client_flow(active : Bool)
- #client_flow? : Bool
- #close
- #confirm : Bool
- #confirm_ack(multiple = false)
- #confirm_count : UInt64
- #confirm_nack(multiple = false)
- #confirm_select(frame)
- #consume(frame)
- #consumers : Array(AvalancheMQ::Client::Channel::Consumer)
- #deliver(frame, msg, redelivered = false)
- #deliver_count : UInt64
- #deliver_count=(deliver_count : UInt64)
- #details_tuple
- #direct_reply_request?(str)
- #get_count : UInt64
- #global_prefetch? : Bool
- #id : UInt16
- #log : Logger
- #name : String
- #next_delivery_tag(queue : Queue, sp, persistent, no_ack, consumer) : UInt64
- #next_msg_headers(frame, ts)
- #prefetch_count : UInt16
- #prefetch_size : UInt32
- #publish_count : UInt64
- #recover(consumer, &)
- #redeliver_count : UInt64
- #redeliver_count=(redeliver_count : UInt64)
- #reject_count : UInt64
- #return_unroutable_count : UInt64
- #running=(running : Bool)
- #running? : Bool
- #send(frame)
- #start_publish(frame)
- #state
- #stats_details
- #update_rates