feat: add logging when enqueueing to transaction queue

the-avid-engineer · the-avid-engineer · commit e9eeecee556e · 2024-10-21T12:23:48.000-07:00
would make it obvious if transactions are being enqueued out of order
diff --git a/src/EntityDb.Common/Transactions/Subscribers/ProcessorQueues/BufferBlockTransactionQueue.cs b/src/EntityDb.Common/Transactions/Subscribers/ProcessorQueues/BufferBlockTransactionQueue.cs
@@ -23,7 +23,11 @@ public BufferBlockTransactionQueue(ILogger<BufferBlockTransactionQueue<TTransact
 
     public void Enqueue(ITransaction transaction)
     {
-        _transactionQueue.Post(transaction);
+        _logger.LogInformation("Enqueueing Transaction {TransactionId} to Transaction Queue.", transaction.Id.Value);
+        
+        var enqueued = _transactionQueue.Post(transaction);
+        
+        _logger.LogInformation("{Enqueued} Transaction {TransactionId} to Transaction Queue.", enqueued, transaction.Id.Value);
     }
 
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,11 @@ public BufferBlockTransactionQueue(ILogger<BufferBlockTransactionQueue<TTransact`
`23`	`23`
`24`	`24`	`public void Enqueue(ITransaction transaction)`
`25`	`25`	`{`
`26`		`- _transactionQueue.Post(transaction);`
	`26`	`+ _logger.LogInformation("Enqueueing Transaction {TransactionId} to Transaction Queue.", transaction.Id.Value);`
	`27`	`+`
	`28`	`+ var enqueued = _transactionQueue.Post(transaction);`
	`29`	`+`
	`30`	`+ _logger.LogInformation("{Enqueued} Transaction {TransactionId} to Transaction Queue.", enqueued, transaction.Id.Value);`
`27`	`31`	`}`
`28`	`32`
`29`	`33`	`protected override async Task ExecuteAsync(CancellationToken stoppingToken)`