Queue.Purge
This method removes all messages from a queue which are not awaiting acknowledgment.
val init : queue:'a -> no_wait:queue_name -> unit -> no_wait -> t
val request :
(Framing.t * Framing.channel_no) ->
t ->
Purge_ok.t Thread.Deferred.t