public function pushed($connection, $queue, JobPayload $payload)
    {
        $this->connection()->pipeline(function ($pipe) use ($connection, $queue, $payload) {
            $this->storeJobReference($pipe, 'recent_jobs', $payload);

            $time = str_replace(',', '.', microtime(true));

            $pipe->hmset(
                $payload->id(), [
                    'id' => $payload->id(),
                    'connection' => $connection,
                    'queue' => $queue,
                    'name' => $payload->decoded['displayName'],
                    'status' => 'pending',
                    'payload' => $payload->value,
                    'created_at' => $time,
                    'updated_at' => $time,
                ]
            );

            $pipe->expireat(
                $payload->id(), Chronos::now()->addMinutes($this->recentJobExpires)->getTimestamp()
            );
        });
    }