Commit a transaction :param callable callback: callback(pika.frame.Method) for method Tx.CommitOk :returns: ``None``. Method frame from the Tx.Commit-ok response is delivered to ``callback`` when provided. :raises ValueError:
(self, callback: Optional[_OnTxCommitCallback] = None)
| 1010 | dict()), callback, [spec.Queue.UnbindOk]) |
| 1011 | |
| 1012 | def tx_commit(self, callback: Optional[_OnTxCommitCallback] = None) -> None: |
| 1013 | """Commit a transaction |
| 1014 | |
| 1015 | :param callable callback: callback(pika.frame.Method) for method Tx.CommitOk |
| 1016 | :returns: ``None``. Method frame from the Tx.Commit-ok response is delivered |
| 1017 | to ``callback`` when provided. |
| 1018 | :raises ValueError: |
| 1019 | |
| 1020 | """ |
| 1021 | self._raise_if_not_open() |
| 1022 | validators.rpc_completion_callback(callback) |
| 1023 | return self._rpc(spec.Tx.Commit(), callback, [spec.Tx.CommitOk]) |
| 1024 | |
| 1025 | def tx_rollback(self, |
| 1026 | callback: Optional[_OnTxRollbackCallback] = None) -> None: |