Queues and Consumers

// amqp091-go — consume and manually ack each delivery.
deliveries, _ := ch.Consume("orders", "", false /* autoAck */, false, false, false, nil)
for d := range deliveries {
    process(d.Body)
    _ = d.Ack(false) // multiple=false
}

# pika — consume with manual ack.
def on_message(ch, method, props, body):
    process(body)
    ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_consume(queue="orders", on_message_callback=on_message, auto_ack=False)
channel.start_consuming()

// amqp-client — consume with manual ack.
DeliverCallback cb = (tag, delivery) -> {
    process(delivery.getBody());
    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
};
channel.basicConsume("orders", false /* autoAck */, cb, t -> {});

// amqplib — consume with manual ack.
await channel.consume("orders", (msg) => {
  if (!msg) return;
  process(msg.content);
  channel.ack(msg);
}, { noAck: false });

// RabbitMQ.Client — consume with manual ack.
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (_, ea) =>
{
    Process(ea.Body.ToArray());
    channel.BasicAck(ea.DeliveryTag, multiple: false);
};
channel.BasicConsume("orders", autoAck: false, consumer);

# bunny — consume with manual ack.
queue.subscribe(manual_ack: true, block: true) do |delivery_info, _props, body|
  process(body)
  channel.ack(delivery_info.delivery_tag)
end

// lapin — consume with manual ack.
let mut consumer = channel.basic_consume(
    "orders", "", BasicConsumeOptions::default(), FieldTable::default()).await?;
while let Some(delivery) = consumer.next().await {
    let delivery = delivery?;
    process(&delivery.data);
    delivery.ack(BasicAckOptions::default()).await?;
}