final public function requeue(Message $message)
    {
        $set = [
            'payload' => $message->getPayload(),
            'earliestGet' => $message->getEarliestGet(),
            'priority' => $message->getPriority(),
            'created' => new UTCDateTime(),
        ];

        $this->collection->updateOne(['_id' => $message->getId()], ['$set' => $set], ['upsert' => true]);
    }
final public function requeue(Message $message)
    {
        $set = [
            'payload' => $message->getPayload(),
            'earliestGet' => $message->getEarliestGet(),
            'priority' => $message->getPriority(),
            'created' => new UTCDateTime(),
        ];

        $this->collection->updateOne(['_id' => $message->getId()], ['$set' => $set], ['upsert' => true]);
    }
final public function requeue ( Message $ message ) { $ set = [ 'payload' => $ message -> getPayload ( ) , 'earliestGet' => $ message -> getEarliestGet ( ) , 'priority' => $ message -> getPriority ( ) , 'created' => new UTCDateTime ( ) , ] ; $ this -> collection -> updateOne ( [ '_id' => $ message -> getId ( ) ] , [ '$set' => $ set ] , [ 'upsert' => true ] ) ; }
Atomically acknowledge and send a message to the queue.

@param Message $message message received from get().

@return void
Atomically acknowledge and send a message to the queue .