package amqp-client-async

You can search for identifiers within the package.

in-package search v0.2.0

Amqp client library, async version

Install

Dune Dependency

github.com Readme Edit opam file Versions (6)

Authors

A

Anders Fugmann

Maintainers

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.Exchange`Source

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

Source

val 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

Source

val 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

Source

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

Remove exchange to exchange binding

Source

val 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

package amqp-client-async

Install

Dune Dependency

Authors

Maintainers

Sources

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

Module Amqp_client_async.ExchangeSource

Module `Amqp_client_async.Exchange`Source