public void AbortTransactionIfNeeded()

in src/Epam.Kafka.PubSub/Publication/Topics/PublicationTopicWrapper.cs [170:193]

• 23 lines of code
• 4 McCabe index (conditional complexity)

    public void AbortTransactionIfNeeded(ActivityWrapper apm)
    {
        if (this.RequireTransaction && this._transactionActive)
        {
            this.Logger.TransactionAbort(this.Monitor.Name);

            using (apm.CreateSpan("abort_transaction"))
            {
                try
                {
                    this.Producer.AbortTransaction();
                }
                catch (Exception e)
                {
                    e.DoNotRetryBatch();
                    throw;
                }
                finally
                {
                    this._transactionActive = false;
                }
            }
        }
    }