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

Transactions. Transactions can be made per channel.

After a transaction is started, all published messages and all changes (queue/exchange bindings, creations or deletions) and message acknowledgements are not visible outside the transaction.

The changes becomes visible after a commit or canceled by call to rollback.

type tx

val start : _ t -> tx Thread.Deferred.t

Start a transacction

val commit : tx -> unit Thread.Deferred.t

Commit an transaction

val rollback : tx -> unit Thread.Deferred.t

Rollback a transaction, discarding all changes and messages