cbq Model

This model is provided to make certain tasks easier when defining and dispatching jobs, chains, and batches.

dispatch

Dispatches a job or chain of jobs.

Arguments
Type
Required
Default
Description

job

string | Job | array<Job>

true

A Job instance or a WireBox ID of a Job instance. If the WireBox ID doesn't exist, a NonExecutableJob instance will be used instead. This allows you to dispatch a Job from a server where that Job component is not defined. If an array is passed, a Job Chain is created and dispatched.

properties

struct

false

{}

A struct of properties for the Job instance.

chain

array<Job>

false

[]

An array of Jobs to chain after this Job.

queue

string

false

The queue the Job belongs to.

connection

string

false

The Connection to dispatch the Job on.

backoff

numeric

false

The amount of time, in seconds, to wait between attempting Jobs.

timeout

numeric

false

The amount of time, in seconds, to wait before treating a Job as erroring.

maxAttempts

numeric

false

The maximum amount of attempts of a Job before treating the Job as failed.

Return: The dispatched Job instance.

cbq.dispatch(
    job = "SendWelcomeEmailJob",
    properties = { "body": "first body" },
    queue = "default"
);

job

Creates a job or chain of jobs to be dispatched.

Arguments
Type
Required
Default
Description

job

string | Job | array<Job>

true

A Job instance or a WireBox ID of a Job instance. If the WireBox ID doesn't exist, a NonExecutableJob instance will be used instead. This allows you to dispatch a Job from a server where that Job component is not defined. If an array is passed, a Job Chain is created and dispatched.

properties

struct

false

{}

A struct of properties for the Job instance.

chain

array<Job>

false

[]

An array of Jobs to chain after this Job.

queue

string

false

The queue the Job belongs to.

connection

string

false

The Connection to dispatch the Job on.

backoff

numeric

false

The amount of time, in seconds, to wait between attempting Jobs.

timeout

numeric

false

The amount of time, in seconds, to wait before treating a Job as erroring.

maxAttempts

numeric

false

The maximum amount of attempts of a Job before treating the Job as failed.

Return: The new Job instance.

cbq.job( "SendWelcomeEmailJob" )
    .setProperties( { "body": "first body" } )
    .onQueue( "default" )
    .dispatch();

chain

Creates a chain of jobs to be ran.

Alias for calling firstJob.chain( otherJobs ).

Arguments
Type
Required
Default
Description

jobs

array<Job>

true

The array of jobs to run in order in a chain.

Return: The first job of the chain with the chained jobs configured to be dispatched.

cbq.chain( [
    cbq.job( "SendWelcomeEmailJob", { "body": "One" }, [], "default" ),
    cbq.job( "SendWelcomeEmailJob", { "body": "Two" }, [], "default", "sync" ),
    cbq.job( "SendWelcomeEmailJob", { "body": "Three" }, [], "default" )
] )
.dispatch()

batch

Creates a PendingBatch from the Jobs provided.

To use batches, you must first configure a BatchRepository.

Learn more in the Batched Jobs documentation.

Arguments
Type
Required
Default
Description

jobs

array<Job>

true

An array of jobs to batch together.

Return: The PendingBatch to be dispatched.

var batch = cbq
    .batch( [
        cbq.job( "ImportCsvJob", { "start": 1, "end": 100 } ),
	cbq.job( "ImportCsvJob", { "start": 101, "end": 200 } ),
	cbq.job( "ImportCsvJob", { "start": 201, "end": 300 } ),
	cbq.job( "ImportCsvJob", { "start": 301, "end": 400 } ),
	cbq.job( "ImportCsvJob", { "start": 401, "end": 500 } )
    ] )
    .then( cbq.job( "ImportCsvSuccessfulJob" ) )
    .catch( cbq.job( "ImportCsvFailedJob" ) )
    .finally( cbq.job( "ImportCsvCompletedJob" ) )
    .dispatch();