Operations on exchanges
val direct_t : [ `Queue of string ] exchange_typeval fanout_t : unit exchange_typeval topic_t : [ `Topic of string ] exchange_typeval match_t : [ `Headers of Amqp_client_lib.Types.header list ] exchange_typeval default : [ `Queue of string ] tval amq_direct : [ `Queue of string ] tval amq_fanout : unit tval amq_topic : [ `Topic of string ] tval amq_match : [ `Headers of Amqp_client_lib.Types.header list ] tval declare :
?passive:bool ->
?durable:bool ->
?auto_delete:bool ->
_ Channel.t ->
'a exchange_type ->
?arguments:Amqp_client_lib.Types.table ->
string ->
'a t Thread.Deferred.tDeclare a exchange
val delete : ?if_unused:bool -> _ Channel.t -> _ t -> unit Thread.Deferred.tDelete exchange
val bind :
_ Channel.t ->
destination:_ t ->
source:'a t ->
'a ->
unit Thread.Deferred.tBind exchange t to exchange using routing_key, so messages are routed from exchange to t
val unbind :
_ Channel.t ->
destination:_ t ->
source:'a t ->
'a ->
unit Thread.Deferred.tRemove exchange to exchange binding
val publish :
'a Channel.t ->
_ t ->
?mandatory:bool ->
routing_key:string ->
Message.message ->
'a Thread.Deferred.tPublish a message directly to an exchange.
val name : _ t -> stringName of the exchange