Process Queue

Process pending messages in the repricing queue.

HTTP: POST /queue/process

Query parameters

Name	Type	Required	Description	Example
limit	integer	no	Maximum number of messages to process (default: 10, max: 100).	10

Notes

Processes messages synchronously and returns results.
Default limit is 10 messages, maximum is 100.
Each message goes through: prepare_data -> reprice -> save workflow.
Results are saved to MySQL changes table and BigQuery.

Sample request

curl -X POST https://admin.elpricing.com/api/queue/process
  -H "Authorization: ApiKey YOUR_API_KEY"
  -H "Content-Type: application/json"
  -d '{"limit":10}'

Interactive call

HTTP MethodMessage LimitMaximum number of messages to process (default: 10, max: 100).

Queue workflow

Tasks are persisted to var/api_queue/tasks.json. Process them with:

php go.php cron:list\nphp go.php cron:go

Logs are written to var/api_queue/logs/{task_id}.log.