Queue (amqp_client_eio.Amqp_client

type t

val message_ttl : int -> string * Types.value

val auto_expire : int -> string * Types.value

val max_length : int -> string * Types.value

val max_length_bytes : int -> string * Types.value

val dead_letter_exchange : string -> string * Types.value

val dead_letter_routing_key : string -> string * Types.value

val maximum_priority : int -> string * Types.value

val declare : 
  _ Channel.t ->
  ?durable:bool ->
  ?exclusive:bool ->
  ?auto_delete:bool ->
  ?passive:bool ->
  ?arguments:Types.table ->
  string ->
  t

val declare_anonymous : 
  _ Channel.t ->
  ?durable:bool ->
  ?exclusive:bool ->
  ?auto_delete:bool ->
  ?passive:bool ->
  ?arguments:Types.table ->
  unit ->
  string

val get : 'a Channel.t -> no_ack:bool -> t -> Cstruct.t list option

type consumer

val consume : 
  _ Channel.t ->
  ?no_local:bool ->
  ?no_ack:bool ->
  ?exclusive:bool ->
  id:string ->
  t ->
  consumer
  * (Amqp_client_eio__Spec.Basic.Deliver.t * Message.content)
      Amqp_client_eio__Utils.Stream.t

val cancel_consumer : _ Channel.t -> consumer -> unit

val publish : 'a Channel.t -> t -> ?mandatory:bool -> Message.content -> 'a

val bind : _ Channel.t -> t -> 'a Exchange.t -> 'a

val unbind : _ Channel.t -> t -> 'a Exchange.t -> 'a

val purge : _ Channel.t -> t -> int

val delete : _ Channel.t -> ?if_unused:bool -> ?if_empty:bool -> t -> int

val name : t -> string

val fake : string -> t