(* $Id$ *)

(** Transactions *)

(** Transactions cover only the [publish] and [ack] methods *)

open Netamqp_types
open Netamqp_rtypes

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 *)