package amqp-client-async

  1. Overview
  2. Docs
package amqp-client-async
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

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 -> _ 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

OCaml

Innovation. Community. Security.

GitHub Discord Twitter Peertube RSS
About
Changelog Releases Industrial Users Academic Users Why OCaml
Ecosystem
Packages Community Events OCaml Planet Jobs
Resources
Install OCaml Get Started Platform Tools Language Manual Standard Library API Books Exercises Papers OCaml Playground Logo
Policies
Carbon Footprint Governance Privacy Code of Conduct