Skip to content

Commit 3334aa3

Browse files
committed
Ensure connection is disposed
1 parent 249d732 commit 3334aa3

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

src/ServiceControl.Audit.Persistence.PostgreSQL/UnitOfWork/PostgreSQLAuditIngestionUnitOfWork.cs

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,10 +25,16 @@ public PostgreSQLAuditIngestionUnitOfWork(NpgsqlConnection connection, DatabaseC
2525

2626
public async ValueTask DisposeAsync()
2727
{
28-
await batch.PrepareAsync();
29-
await batch.ExecuteNonQueryAsync();
30-
await batch.DisposeAsync();
31-
await connection.DisposeAsync();
28+
try
29+
{
30+
await batch.PrepareAsync();
31+
await batch.ExecuteNonQueryAsync();
32+
}
33+
finally
34+
{
35+
await batch.DisposeAsync();
36+
await connection.DisposeAsync();
37+
}
3238
}
3339

3440
public Task RecordProcessedMessage(ProcessedMessage processedMessage, ReadOnlyMemory<byte> body, CancellationToken cancellationToken)

0 commit comments

Comments
 (0)