simplario / quedis

     * @return $this

     * @throws QueueException

     */

    public function bury($mixed)

    {

        $payload = $this->payload($mixed);

        $this->checkMessageFlow($payload->getState(), 'bury');

        $result = $this->getRedis()->transaction(function ($tx) use ($payload) {

            /** @var $tx \Predis\Client */

            $tx->zrem($this->getKey($payload->getQueue(), self::STATE_RESERVED), $payload->getToken());

            $tx->zadd($this->getKey($payload->getQueue(), self::STATE_BURIED), time(), $payload->getToken());

            $tx->hset($this->ns(self::NS_MESSAGE_TO_STATE), $payload->getToken(), self::STATE_BURIED);

        });

        if (in_array(false, $result, true)) {

            throw new QueueException("The message bury error.");

        }

        return $this;

    }

    /**

     * @param Message|string $mixed

     * @return $this

     * @throws QueueException

     */

    public function kick($mixed)

    {

        $payload = $this->payload($mixed);

        $this->checkMessageFlow($payload->getState(), 'kick');

        $result = $this->getRedis()->transaction(function ($tx) use ($payload) {

            /** @var $tx \Predis\Client */

            $tx->zrem($this->getKey($payload->getQueue(), self::STATE_BURIED), $payload->getToken());

            $tx->rpush($this->getKey($payload->getQueue(), self::STATE_READY), $payload->getToken());

            $tx->hset($this->ns(self::NS_MESSAGE_TO_STATE), $payload->getToken(), self::STATE_READY);

        });

        if (in_array(false, $result, true)) {

            throw new QueueException("The message kicked error");

        }

        return $this;

    }

    /**

     * @param Message|string $mixed