package amqp-client-async

  1. Overview
  2. Docs
Amqp client library, async version

Install 

dune-project
 Dependency

github.com Readme Edit opam file Versions (6)

Authors

  1. A
    Anders Fugmann

Maintainers

  1. A
    Anders Fugmann <anders@fugmann.net>

Sources

2.3.0.tar.gz
md5=9db83accd0dfa9231c3f2ca0de9c8d9f
sha512=921c3f4d0d655dc5caa5c89fe8c4309a6e22d91167676062e0e73f3007b0b5de20e7b461aefdddca6dbdf716d57d90eaefb7e974ae218cce0f0a20fb461c965d

doc/amqp-client-async/Amqp_client_async/Exchange/index.html

Module Amqp_client_async.ExchangeSource

Operations on exchanges

Sourcetype _ t
Sourcetype _ exchange_type
Sourceval direct_t : [ `Queue of string ] exchange_type
Sourceval fanout_t : unit exchange_type
Sourceval topic_t : [ `Topic of string ] exchange_type
Sourceval match_t : [ `Headers of Amqp_client_lib.Types.header list ] exchange_type
Sourceval default : [ `Queue of string ] t
Sourceval amq_direct : [ `Queue of string ] t
Sourceval amq_fanout : unit t
Sourceval amq_topic : [ `Topic of string ] t
Sourceval amq_match : [ `Headers of Amqp_client_lib.Types.header list ] t
Sourceval declare : ?passive:bool -> ?durable:bool -> ?auto_delete:bool -> ?internal:bool -> _ Channel.t -> 'a exchange_type -> ?arguments:Amqp_client_lib.Types.table -> string -> 'a t Thread.Deferred.t

Declare a exchange

Sourceval delete : ?if_unused:bool -> _ Channel.t -> _ t -> unit Thread.Deferred.t

Delete exchange

Sourceval bind : _ Channel.t -> destination:_ t -> source:'a t -> 'a -> unit Thread.Deferred.t

Bind exchange t to exchange using routing_key, so messages are routed from exchange to t

Sourceval unbind : _ Channel.t -> destination:_ t -> source:'a t -> 'a -> unit Thread.Deferred.t

Remove exchange to exchange binding

Sourceval publish : 'a Channel.t -> _ t -> ?mandatory:bool -> routing_key:string -> Message.message -> 'a Thread.Deferred.t

Publish a message directly to an exchange.

Sourceval name : _ t -> string

Name of the exchange