module Netamqp_exchange:Managing exchangessig
..end
typeexchange_name =
string
val amq_direct : exchange_name
val amq_fanout : exchange_name
val amq_topic : exchange_name
val amq_match : exchange_name
amq_direct
which is mandatory.typeexchange_type =
string
val direct : exchange_type
val fanout : exchange_type
val topic : exchange_type
val headers : exchange_type
val system : exchange_type
val declare_passively_e : channel:Netamqp_channel.channel_obj ->
exchange_name:exchange_name ->
?no_wait:bool -> unit -> unit Uq_engines.engine
val declare_passively_s : channel:Netamqp_channel.channel_obj ->
exchange_name:exchange_name -> ?no_wait:bool -> unit -> unit
exchange_name
exists,
and raise a channel error if not.
no_wait
: see belowval declare_e : channel:Netamqp_channel.channel_obj ->
exchange_name:exchange_name ->
exchange_type:exchange_type ->
?durable:bool ->
?no_wait:bool ->
?arguments:Netamqp_rtypes.table -> unit -> unit Uq_engines.engine
val declare_s : channel:Netamqp_channel.channel_obj ->
exchange_name:exchange_name ->
exchange_type:exchange_type ->
?durable:bool ->
?no_wait:bool -> ?arguments:Netamqp_rtypes.table -> unit -> unit
Arguments:
exchange_name
: The nameexchange_type
: The typedurable
: whether to keep the exchange instance across server restartsno_wait
: whether not to wait for the response of the declaration.
This is faster, but errors are not immediately reported.arguments
: Arguments. The standard exchange types do not need
arguments.val delete_e : channel:Netamqp_channel.channel_obj ->
exchange_name:exchange_name ->
?if_unused:bool -> ?no_wait:bool -> unit -> unit Uq_engines.engine
val delete_s : channel:Netamqp_channel.channel_obj ->
exchange_name:exchange_name ->
?if_unused:bool -> ?no_wait:bool -> unit -> unit
Options:
exchange_name
: the name of the instanceif_unused
: only delete if there are no queue bindingsno_wait
: whether not to wait for the response of the declaration.
This is faster, but errors are not immediately reported.