Method GetTransactionFromQueue

queue.go:275–298

GetTransactionFromQueue retrieves a transaction from the queue by its ID. Parameters: - transactionID string: The ID of the transaction to retrieve. Returns: - *model.Transaction: A pointer to the Transaction model if found. - error: An error if the transaction could not be retrieved.

(transactionID string)

// - *model.Transaction: A pointer to the Transaction model if found.
// - error: An error if the transaction could not be retrieved.
func (q *Queue) GetTransactionFromQueue(transactionID string) (*model.Transaction, error) {
	for i := 1; i <= q.config.Queue.NumberOfQueues; i++ {
		queueName := fmt.Sprintf("%s_%d", q.config.Queue.TransactionQueue, i)
		task, err := q.Inspector.GetTaskInfo(queueName, transactionID)
		if err == nil && task != nil {
			var txn model.Transaction
			if err := json.Unmarshal(task.Payload, &txn); err != nil {
				return nil, err
			}
			return &txn, nil
		}
	}
	if q.config.Queue.EnableHotLane {
		task, err := q.Inspector.GetTaskInfo(q.config.Queue.HotQueueName, transactionID)
		if err == nil && task != nil {
			var txn model.Transaction
			if err := json.Unmarshal(task.Payload, &txn); err != nil {
				return nil, err
			}
			return &txn, nil
		}
	}
	return nil, nil // Return nil if transaction is not found in any queue
}

// queueInflightCommit enqueues a task to handle inflight commit for a transaction.
//