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 updates the secret used to authenticate this connection. It is used when secrets have an expiration date and need to be renewed, like OAuth 2 tokens.

type t = {

new_secret : Amqp_client_lib.Types.longstr;
(*
The new secret.
*)
reason : Amqp_client_lib.Types.shortstr;
(*
The reason for the secret update.
*)

}

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

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