diff --git a/src/DotNetCore.CAP.PostgreSql/IDbContextTransaction.CAP.cs b/src/DotNetCore.CAP.PostgreSql/IDbContextTransaction.CAP.cs index ac5f87d..8bd7619 100644 --- a/src/DotNetCore.CAP.PostgreSql/IDbContextTransaction.CAP.cs +++ b/src/DotNetCore.CAP.PostgreSql/IDbContextTransaction.CAP.cs @@ -16,7 +16,7 @@ namespace Microsoft.EntityFrameworkCore.Storage public CapEFDbTransaction(ICapTransaction transaction) { _transaction = transaction; - var dbContextTransaction = (IDbContextTransaction) _transaction.DbTransaction; + var dbContextTransaction = (IDbContextTransaction)_transaction.DbTransaction; TransactionId = dbContextTransaction.TransactionId; } @@ -42,7 +42,7 @@ namespace Microsoft.EntityFrameworkCore.Storage public Task RollbackAsync(CancellationToken cancellationToken = default) { - return _transaction.CommitAsync(cancellationToken); + return _transaction.RollbackAsync(cancellationToken); } public Guid TransactionId { get; }