module

Amqp::Wire::AmqpZeroNineOne::BasicMethods

Instance methods

decode_deliver_frame_payload(payload : Bytes) : Deliver | Nil
Source
publish_frame(channel : UInt16, exchange : String, routing_key : String, mandatory : Bool, immediate : Bool = false) : Bytes
Source
write_ack_frame(io : IO, channel : UInt16, delivery_tag : UInt64, multiple : Bool) : Nil
Source
write_nack_frame(io : IO, channel : UInt16, delivery_tag : UInt64, multiple : Bool, requeue : Bool) : Nil
Source
write_publish_frame(io : IO, channel : UInt16, exchange : String, routing_key : String, mandatory : Bool, immediate : Bool = false) : Nil
Source
write_reject_frame(io : IO, channel : UInt16, delivery_tag : UInt64, requeue : Bool) : Nil
Source

Nested types