push(self::QUEUE_COMPLETE, $consumer, $score); } /** * @param $consumer * @return false|int * @throws ComponentException */ public function del(Consumer $consumer) { return $this->pop(self::QUEUE_COMPLETE, $consumer); } }