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()
            );
        });
    }
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()
            );
        });
    }
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 ( ) ) ; } ) ; }
Insert the job into storage.

@param  string  $connection
@param  string  $queue
@param  \Laravel\Horizon\JobPayload  $payload
@return void
Insert the job into storage .