AMQP::Client::Channel
Instance methods
Acknowledge a message with delivery_tag, or all message up and including delivery_tag if multiple set set
Cancel the consumer with the consumer_tag Even with no_wait = false the method will return immediately, but outstanding deliveries will be processed.
Consume messages from a queue
- Make sure to eventually ack or reject each message if no_ack is false
- The exclusive flags ensures that only a single consumer receives messages from the queue at the time
- The method will block if the flag is set, until the consumer/channel/connection is closed or the callback raises an exception
- To let multiple fibers process messages increase work_pool Make sure to handle all exceptions in the consume block, as unhandeled exceptions will cause the channel to be closed (to prevent dangling unacked messages and exception floods).
Get a single message from a queue The message must eventually be acked or rejected if no_ack is false
Reject a message with delivery_tag, optionally requeue it Reject all message up to and including delivery_tag if multiple is true
Publish a bytes message, to an exchange with routing_key
Publish a string message, to an exchange with routing_key
Publish an io message, to an exchange with routing_key Only data from the current position of the IO to the end will be published. The position will be restored after publish.
Publish a message with a set bytesize, to an exchange with routing_key
Set prefetch limit to count messages, no more messages will be delivered to the consumer until one or more message have been acknowledged or rejected
Tell the broker to either deliver all unacknowledge messages again if requeue is false or rejecting all if requeue is true
Unacknowledged messages retrived by basic_get are requeued regardless.
Reject a message with delivery_tag, optionally requeue it
Close the channel The reason might be logged by the server
Sets the channel in publish confirm mode, each published message will be acked or nacked
Convinence method for Exchange handling
Bind an exchange to another exchange
Declares an exchange
Unbind an exchange from another exchange
Appends a String representation of this object which includes its class name, its object address and the values of all instance variables.
class Person
def initialize(@name : String, @age : Int32)
end
end
Person.new("John", 32).inspect # => #<Person:0x10fd31f20 @name="John", @age=32>Callback that will be called if a consumer is cancelled by the server The argument to the callback is the consumer tag
Declares a queue with a name, by default durable and not auto-deleted
Declares a temporary queue, which won't be durable and auto-deleted when not used anymore
Bind a queue to an exchange, with a routing_key and optionally some arguments
Declare a queue with name passive will raise if the queue doesn't already exists, other arguments are ignored durable will make the queue durable on the server (note that messages have have the persistent flag set to make the messages persistent) exclusive will make the queue exclusive to the channel and will be deleted when the channel is closed auto_delete will delete the queue when the last consumer as stopped consuming no_wait will cause the method to return without waiting for a confirmation from the server
Delete a queue
Purge/empty a queue, will return the number of messages deleted
Unbind a queue from an exchange, with a routing_key and optionally some arguments
Commits a transaction if the block returns, rolls back the transaction if the block raises an exception
Returns when there are no unconfirmed publishes on the channel Raises if there was any negative acknowledgements