package amqp-client-async

You can search for identifiers within the package.

in-package search v0.2.0

amqp-client-async
- Library amqp-client-async
  - Amqp_client_async
    
    Amqp
    
    Channel
    
    Connection
    
    Exchange
    
    Message
    
    Queue
    
    Rpc
    
    Types
    
    Channel
    
    Transaction
    
    Connection
    
    Constants
    
    Exchange
    
    Framing
    
    Message
    
    Protocol_helpers
    
    Protocol
    
    Io
    
    Queue
    
    Rpc
    
    Client
    
    Server
    
    Spec
    
    Confirm
    
    Select_ok
    
    Select
    
    Tx
    
    Select_ok
    
    Select
    
    Commit_ok
    
    Commit
    
    Rollback_ok
    
    Rollback
    
    Basic
    
    Content
    
    Qos_ok
    
    Qos
    
    Consume_ok
    
    Consume
    
    Cancel_ok
    
    Cancel
    
    Publish
    
    Return
    
    Deliver
    
    Get_ok
    
    Get_empty
    
    Get
    
    Ack
    
    Reject
    
    Recover_async
    
    Recover
    
    Recover_ok
    
    Nack
    
    Queue
    
    Declare_ok
    
    Declare
    
    Bind_ok
    
    Bind
    
    Unbind_ok
    
    Unbind
    
    Purge_ok
    
    Purge
    
    Delete_ok
    
    Delete
    
    Exchange
    
    Declare_ok
    
    Declare
    
    Delete_ok
    
    Delete
    
    Bind_ok
    
    Bind
    
    Unbind_ok
    
    Unbind
    
    Channel
    
    Open_ok
    
    Open
    
    Flow_ok
    
    Flow
    
    Close_ok
    
    Close
    
    Connection
    
    Start_ok
    
    Start
    
    Secure_ok
    
    Secure
    
    Tune_ok
    
    Tune
    
    Open_ok
    
    Open
    
    Close_ok
    
    Close
    
    Blocked
    
    Unblocked
    
    Thread
    
    Deferred
    
    List
    
    Ivar
    
    Reader
    
    Writer
    
    Tcp
    
    Log
    
    Pipe
    
    Writer
    
    Reader
    
    Scheduler
- Sources
  - amqp-client-async
    
    amqp.ml
    
    amqp_client_async.ml
    
    channel.ml
    
    connection.ml
    
    constants.ml
    
    exchange.ml
    
    framing.ml
    
    message.ml
    
    protocol_helpers.ml
    
    queue.ml
    
    rpc.ml
    
    spec.ml
    
    thread.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Tx.Rollback`Source

This method abandons all message publications and acknowledgments performed in the current transaction. A new transaction starts immediately after a rollback. Note that unacked messages will not be automatically redelivered by rollback; if that is required an explicit recover call should be issued.

Sourcetype t = unit

Sourceval init : unit -> unit

Source

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

package amqp-client-async

Module Tx.RollbackSource

Module `Tx.Rollback`Source