abortTransaction method

StompTransaction abortTransaction(
  1. String id
)

Aborts a transaction

Implementation

StompTransaction abortTransaction(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.markAborted();
  _abortController.add(transaction);

  return transaction;
}