<?php

// 队列配置
$queueName = 'myqueue';
$redisConfig = [
  'host' => '127.0.0.1',
  'port' => '6379',
  'index' => '0'
];

// 添加任务
$data = [
 'k1' => 'v1',
 'k2' => 'v2',
];

echo "Queue name: " . $queueName . "\n";

try {
  // create queue
  $redisQueue = new RedisQueue($queueName, $redisConfig);

  // add to queue
  $index = $redisQueue->add($data);

  echo "Data index: " . $index . "\n";  // index of added data

} catch (RedisQueueException $e) {
  echo $e->getMessage();
}

<?php

  // 队列配置
  $queueName = 'myqueue';
  $redisConfig = [
    'host' => '127.0.0.1',
    'port' => '6379',
    'index' => '0'
    ];

  echo "Queue name: " . $queueName . "\n";

  try {
    // create queue
    $redisQueue = new RedisQueue($queueName, $redisConfig);

    // fetch from queue
    $data = $redisQueue->get();
    echo "Fetched data:\n";
    var_dump($data);

    // get the index of current data
    echo "Current Index:";
    $currentIndex = $redisQueue->getCurrentIndex();
    var_dump($currentIndex);
    echo $currentIndex;


    /* ... */
    $success = True;  //  process result
    //$success = False;  //  process result
    /* ... */


    if ($success) {  // success
      $ret = $redisQueue->remove();
      if (!empty($ret)) {
        echo "\nData removed !";
      }
    } else { // failed
      echo "\nRollback current data";
      $redisQueue->rollback();  // if retry times up to max, the index will be transfer to blocked list
    }
  } catch (RedisQueueException $e) {
    echo $e->getMessage();
  }