package amqp-client

  1. Overview
  2. Docs
Amqp client library compatable with async and lwt.

Install

Dune Dependency

Authors

Maintainers

Sources

1.1.4.tar.gz
sha256=f3ce83cf82d63f307e8cc7c07938e63fdb57d9185d66b724587847c66a1d8985
md5=9094e13ffda6ab9ee06eca6588fe841d

Description

This library provides high level client bindings for amqp. The library is tested against rabbitmq, but should work against other amqp servers. The library is written in pure OCaml and supports both Async and Lwt for concurrency.

Published: 16 Nov 2017

README

OCaml client library for AMQP

Amqp-client is a AMQP client library written in pure OCaml. The library implements AMQP protocol version 0.9.1 as well as RabbitMQ-specific extensions. It supports both Core Async and Lwt threading models.

Amqp-client is tested extensively against RabbitMQ, but should work with any AMQP server.

The library exposes low level protocol handling though Amqp_spec and Amqp_framing modules as well as a high level interface though module Amqp.

The high level interface exposes usage patterns such as

  • create queue

  • consume from a queue

  • post message to a queue

  • create exchange

  • bind a queue to an exchange

  • post message to an exchange

  • RPC client / server

The library requires all resources to be explicitly allocated to avoid crashes because a service is replying on other services to allocate AMQP resources (exchanges, queues etc.).

Channels and consumers are tagged with an id, host name, pid etc. to ease tracing on AMQP level.

Documentation for the API (async version).

Build infrastructure

The system is not functorized over an abstraction to the threading model. Instead the build system chooses which threading model abstraction to be used and stacially compiles it in. This has the advantage that files do not need to carry functor boilerplate

The disadvantage is that it does not allow users to supply their own threading model implementation.

To build the library

make build

make install will install Lwt and Async depending on availability of Async / Lwt.

Using the library

To compile using Async do:

ocamlfind ocamlopt -thread -package amqp-client.async myprog.ml

To compile using the Lwt version of the library do:

ocamlfind ocamlopt -thread -package amqp-client.lwt myprog.ml

Example

open Async

let host = "localhost"

let run () =
  Amqp.Connection.connect ~id:"MyConnection" host >>= fun connection ->
  Amqp.Connection.open_channel ~id:"MyChannel" Amqp.Channel.no_confirm connection >>= fun channel ->
  Amqp.Queue.declare channel "MyQueue" >>= fun queue ->
  Amqp.Queue.publish channel queue (Amqp.Message.make "My Message Payload") >>= function `Ok ->
  Amqp.Channel.close channel >>= fun () ->
  Amqp.Connection.close connection >>= fun () ->
  Shutdown.shutdown 0; return ()

let _ =
  don't_wait_for (run ());
  Scheduler.go ()

Compile with:

$ ocamlfind ocamlopt -thread -package amqp-client.async amqp_example.ml -linkpkg -o amqp_example

More examples are available here: https://github.com/andersfugmann/amqp-client/tree/master/tests

Dependencies (4)

  1. ocplib-endian >= "0.6"
  2. xml-light build
  3. jbuilder >= "1.0+beta7"
  4. ocaml >= "4.03.0"

Dev Dependencies (2)

  1. lwt with-test
  2. async with-test

Used by

None

Conflicts (2)

  1. lwt < "2.4.6"
  2. async >= "v0.10"
OCaml

Innovation. Community. Security.