module Netamqp_tx: sig .. end
Transactions
Transactions cover only the
publish and
ack methods
val select_e : channel:Netamqp_channel.channel_obj -> unit -> unit Uq_engines.engine
val select_s : channel:Netamqp_channel.channel_obj -> unit -> unit
Selects transactions for this channel
val commit_e : channel:Netamqp_channel.channel_obj -> unit -> unit Uq_engines.engine
val commit_s : channel:Netamqp_channel.channel_obj -> unit -> unit
Commits the current transaction and starts a new one
val rollback_e : channel:Netamqp_channel.channel_obj -> unit -> unit Uq_engines.engine
val rollback_s : channel:Netamqp_channel.channel_obj -> unit -> unit
Rolls the current transaction back and starts a new one
