php-beanstalkd消息队列类实例分享

/**

• Inspect the job with the shortest delay left.
• @return string|boolean false on error otherwise the body of the job.
  */
  public function peekDelayed() {
  $this->_write('peek-delayed');
  return $this->_peekRead();
  }

/**

• Inspect the next job in the list of buried jobs.
• @return string|boolean false on error otherwise the body of the job.
  */
  public function peekBuried() {
  $this->_write('peek-buried');
  return $this->_peekRead();
  }

/**

• Handles response for all peek methods.
• @return string|boolean false on error otherwise the body of the job.
  */
  protected function _peekRead() {
  $status = strtok($this->_read(),' ');

switch ($status) {
  case 'FOUND':
    return [
      'id' => (integer) strtok(' '),'body' => $this->_read((integer) strtok(' '))
    ];
  case 'NOT_FOUND':
  default:
    $this->_error($status);
    return false;
}

}

（编辑：网站开发网_安阳站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!