Please add the following method to your amqp.inc source file (line numbers may
be slightly off). Doing this allowed me to support transactions with RabbitMQ.
I based it on the Python implementation of the same method.
@@ -1372,6 +1377,15 @@
$msg = $this->wait();
}
+
+ public function tx_commit()
+ {
+ $this->send_method_frame(array(90, 20));
+ return $this->wait(array(
+ "90,21" //Channel.tx_commit_ok
+ ));
+ }
+
Original issue reported on code.google.com by quasikeith on 1 Nov 2010 at 11:49
Original issue reported on code.google.com by
quasikeith
on 1 Nov 2010 at 11:49