commitTransaction method

StompTransaction commitTransaction(
  1. String id
)

Commits a transaction

Implementation

StompTransaction commitTransaction(String id) {
  final transaction = _transactions[id];
  if (transaction == null) {
    throw StompTransactionException('Transaction not found', id);
  }

  if (!transaction.isActive) {
    throw StompTransactionException('Transaction is not active', id);
  }

  transaction.markCommitted();
  _commitController.add(transaction);

  return transaction;
}