package amqp-client-async

You can search for identifiers within the package.

in-package search v0.2.0

amqp-client-async
- Amqp_client_async
  - Amqp
  - Channel
    
    Transaction
  - Connection
  - Constants
  - Exchange
  - Framing
  - Message
  - Protocol_helpers
  - Queue
  - Rpc
    
    Client
    
    Server
  - Spec
    
    Basic
    
    Ack
    
    Cancel
    
    Cancel_ok
    
    Consume
    
    Consume_ok
    
    Content
    
    Deliver
    
    Get
    
    Get_empty
    
    Get_ok
    
    Nack
    
    Publish
    
    Qos
    
    Qos_ok
    
    Recover
    
    Recover_async
    
    Recover_ok
    
    Reject
    
    Return
    
    Channel
    
    Close
    
    Close_ok
    
    Flow
    
    Flow_ok
    
    Open
    
    Open_ok
    
    Confirm
    
    Select
    
    Select_ok
    
    Connection
    
    Blocked
    
    Close
    
    Close_ok
    
    Open
    
    Open_ok
    
    Secure
    
    Secure_ok
    
    Start
    
    Start_ok
    
    Tune
    
    Tune_ok
    
    Unblocked
    
    Update_secret
    
    Update_secret_ok
    
    Exchange
    
    Bind
    
    Bind_ok
    
    Declare
    
    Declare_ok
    
    Delete
    
    Delete_ok
    
    Unbind
    
    Unbind_ok
    
    Queue
    
    Bind
    
    Bind_ok
    
    Declare
    
    Declare_ok
    
    Delete
    
    Delete_ok
    
    Purge
    
    Purge_ok
    
    Unbind
    
    Unbind_ok
    
    Tx
    
    Commit
    
    Commit_ok
    
    Rollback
    
    Rollback_ok
    
    Select
    
    Select_ok
  - Thread
    
    Deferred
    
    List
    
    Ivar
    
    Log
    
    Pipe
    
    Reader
    
    Writer
    
    Reader
    
    Scheduler
    
    Tcp
    
    Writer

Legend:
Library
Module
Module type
Parameter
Class
Class type

This method indicates that a connection has been blocked and does not accept new publishes.

type t = {

reason : Amqp_client_lib.Types.shortstr;
(*
The reason the connection was blocked.
*)

}

val init : reason:Amqp_client_lib.Types.shortstr -> unit -> t

val reply : 
  ?once:bool ->
  (Framing.t * Framing.channel_no) ->
  t Async_kernel.Deferred.t

val request : (Framing.t * Framing.channel_no) -> t -> unit Thread.Deferred.t