class SolrReindexQueuedJob extends SolrReindexQueuedJobBase (View source)

Represents a queuedjob which invokes a reindex

Properties

protected bool $isComplete

Flag whether this job is done

from  SolrReindexQueuedJobBase
protected array $messages

List of messages

from  SolrReindexQueuedJobBase
protected LoggerInterface $logger

Logger to use for this job

from  SolrReindexQueuedJobBase
protected int $batchSize

Size of each batch to run

protected string $taskName

Name of devtask Which invoked this Not necessary for re-index processing performed entirely by queuedjobs

protected array|string $classes

List of classes to filter

Methods

public
__construct($batchSize = null, $taskName = null, $classes = null)

No description

protected
LoggerInterface
getLogger()

Gets a logger for this job

public
setLogger(LoggerInterface $logger)

Assign custom logger for this job

public
getJobData()

Return the current job state as an object containing data

public
setJobData(int $totalSteps, int $currentStep, bool $isComplete, stdClass $jobData, array $messages)

Sets data about the job

protected
getHandler()

Get the reindex handler

public
jobFinished()

Returns true or false to indicate that this job is finished

public
prepareForRestart()

Called whenever a job is restarted for whatever reason.

public
setup()

Setup this queued job. This is only called the first time this job is executed (ie when currentStep is 0)

public
afterComplete()

No description

public
getJobType()

What type of job is this? Options are

  • QueuedJob::IMMEDIATE
  • QueuedJob::QUEUED
  • QueuedJob::LARGE

public
addMessage(string $message)

Add an arbitrary text message into a job

public
string
getSignature()

Gets a unique signature for this job and its current parameters.

public
string
getTitle()

Gets a title for the job that can be used in listings

public
process()

A job is run within an external processing loop that will call this method while there are still steps left to complete in the job.

public
int
getBatchSize()

Get size of batch

Details

__construct($batchSize = null, $taskName = null, $classes = null)

No description

Parameters

$batchSize
$taskName
$classes

protected SearchLogFactory getLoggerFactory()

No description

Return Value

SearchLogFactory

protected LoggerInterface getLogger()

Gets a logger for this job

Return Value

LoggerInterface

setLogger(LoggerInterface $logger)

Assign custom logger for this job

Parameters

LoggerInterface $logger

getJobData()

Return the current job state as an object containing data

stdClass ( 'totalSteps' => the total number of steps in this job - this is relayed to the user as an indicator of time 'currentStep' => the current number of steps done so far. 'isComplete' => whether the job is finished yet 'jobData' => data that the job wants persisted when it is stopped or started 'messages' => a cumulative array of messages that have occurred during this job so far )

setJobData(int $totalSteps, int $currentStep, bool $isComplete, stdClass $jobData, array $messages)

Sets data about the job

is an inverse of the getJobData() method, but being explicit about what data is set

Parameters

int $totalSteps
int $currentStep
bool $isComplete
stdClass $jobData
array $messages

protected SolrReindexHandler getHandler()

Get the reindex handler

Return Value

SolrReindexHandler

jobFinished()

Returns true or false to indicate that this job is finished

prepareForRestart()

Called whenever a job is restarted for whatever reason.

This is a separate method so that broken jobs can do some fixup before restarting.

setup()

Setup this queued job. This is only called the first time this job is executed (ie when currentStep is 0)

afterComplete()

No description

getJobType()

What type of job is this? Options are

  • QueuedJob::IMMEDIATE
  • QueuedJob::QUEUED
  • QueuedJob::LARGE

addMessage(string $message)

Add an arbitrary text message into a job

Parameters

string $message

string getSignature()

Gets a unique signature for this job and its current parameters.

This is used so that a job isn't added to a queue multiple times - this for example, an indexing job might be added every time an item is saved, but it isn't processed immediately. We dont NEED to do the indexing more than once (ie the first indexing will still catch any subsequent changes), so we don't need to have it in the queue more than once.

If you have a job that absolutely must run multiple times, the AbstractQueuedJob class provides a time sensitive randomSignature() method that can be used for returning a random signature each time

Return Value

string

string getTitle()

Gets a title for the job that can be used in listings

Return Value

string

process()

A job is run within an external processing loop that will call this method while there are still steps left to complete in the job.

Typically, this method should process just a small amount of data - after calling this method, the process loop will save the current state of the job to protect against potential failures or errors.

int getBatchSize()

Get size of batch

Return Value

int