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
    
    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 opens a connection to a virtual host, which is a collection of resources, and acts to separate multiple application domains within a server. The server may apply arbitrary limits per virtual host, such as the number of each type of entity that may be used, per connection and/or in total.

type t = {

virtual_host : path;
(*
The name of the virtual host to work with.
*)

}

val init : virtual_host:path -> unit -> 'a -> 'b -> t

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