package amqp-client-async
Legend:
Library
Module
Module type
Parameter
Class
Class type

This method indicates that a connection has been blocked and does not accept new publishes.

type t = {
  1. reason : Amqp_client_lib.Types.shortstr;
}
val init : reason:Amqp_client_lib.Types.shortstr -> unit -> t
val reply : ?once:bool -> (Framing.t * Framing.channel_no) -> t Async_kernel.Deferred.t
val request : (Framing.t * Framing.channel_no) -> t -> unit Thread.Deferred.t