amalgame-rabbitmq

Vue d'ensemble

Implémentation du protocole AMQP 0.9.1 via le binding dynamic-link à librabbitmq (le client C officiel). Compatible RabbitMQ, Apache Qpid, CloudAMQP. AMQP 0.9.1 reste le protocole de référence pour les workflows : exchanges + queues + bindings + routing keys.

Caractéristiques

• ✓Exchanges (direct, fanout, topic, headers)
• ✓Queues durables, exclusives, auto-delete
• ✓Publish + Consume + Ack / Nack / Reject
• ✓TLS via la chaîne librabbitmq
• ✓Compatible : RabbitMQ, Apache Qpid, CloudAMQP

Exemple

Exemple minimal d'utilisation — recopiable tel quel après l'install.

amc package add rabbitmq

let conn = AmqpConn.Connect("amqp://guest:guest@localhost:5672")
let ch = conn.Channel()
ch.QueueDeclare("tasks", true, false, false)
ch.Publish("", "tasks", "process-image:42")
ch.Consume("tasks", fn(msg) {
    process(msg.Body)
    ch.Ack(msg.DeliveryTag)
})

Packages liés