Method QueueInflightExpiry

queue.go:208–213

QueueInflightExpiry handles queuing a transaction for inflight expiration. This method is separate from the main Enqueue to ensure expiration is handled regardless of whether the transaction is queued or processed immediately. Parameters: - ctx context.Context: The context for the operation. - tran

(ctx context.Context, transaction *model.Transaction)

// Returns:
// - error: An error if the expiration could not be queued.
func (q *Queue) QueueInflightExpiry(ctx context.Context, transaction *model.Transaction) error {
	if !transaction.InflightExpiryDate.IsZero() {
		return q.queueInflightExpiry(transaction.TransactionID, transaction.InflightExpiryDate)
	}
	return nil
}

// geTask generates a task for a transaction and assigns it to a specific queue based on the balance ID.
// It ensures that transactions are evenly distributed across multiple queues by hashing the balance ID.