package amqp-client-lwt

You can search for identifiers within the package.

in-package search v0.2.0

amqp-client-lwt
- Library amqp-client-lwt
  - Amqp_client_lwt
    
    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
    
    Update_secret_ok
    
    Update_secret
    
    Thread
    
    Deferred
    
    List
    
    Ivar
    
    Reader
    
    Writer
    
    Tcp
    
    Log
    
    Pipe
    
    Writer
    
    Reader
    
    Scheduler
- Sources
  - amqp-client-lwt
    
    amqp.ml
    
    amqp_client_lwt.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 `Queue.Purge`Source

This method removes all messages from a queue which are not awaiting acknowledgment.

Sourcetype t = {

queue : queue_name;
(*
Specifies the name of the queue to purge.
*)
no_wait : no_wait;

}

Sourceval init : queue:'a -> no_wait:queue_name -> unit -> no_wait -> t

Source

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

package amqp-client-lwt

Module Queue.PurgeSource

Module `Queue.Purge`Source