1. trait
  2. Hypervel
  3. \
  4. Queue
  5. \
  6. Concerns
  7. \
  8. StagesOutboxJobs

StagesOutboxJobs

trait StagesOutboxJobs

Constants

protected OUTBOX_FORWARDED_CONTEXT_KEY

Properties

protected bool $dispatchViaOutbox

Whether this connection stages jobs through the outbox by default.

Methods

bool
shouldDispatchViaOutbox(object|string $job)

Determine whether the job selects outbox delivery.

mixed
withOutboxForwarding(array|null $forwarded, callable $callback)

Run a child attempt or handler with its own forwarding context.

bool
shouldStageViaOutbox(object|string $job)

Determine whether this driver needs SQL staging for the selected job.

string|null
resolveOutboxCommitConnection(DatabaseTransactionsManager $transactions, object|string $job)

Select an explicit transaction for a local or failover after-commit fallback.

string
enqueueViaOutbox(object|string $job, string $payload, string|null $queue, DateInterval|DateTimeInterface|int|null $delay)

Stage a single job through its normal guarded enqueue lifecycle.

array
stageOutboxJobs(array $jobs, mixed $data, string|null $queue)

Stage selected jobs in owner groups and return the direct remainder.

array
prepareOutboxRow(object|string $job, string $payload, string|null $queue, DateInterval|DateTimeInterface|int|null $delay)

Build a byte-preserving row from a finalized payload.

string|null
resolveOutboxQueue(string|null $queue)

Expand the logical destination without applying publication-time forwarding.

string
preparePayloadForOutbox(object|string $job, string $payload)

Add metadata required while the original job is still available.

array
prepareOutboxOptions(object|string $job, string|null $queue, string $payload)

Capture transport options that cannot be recovered from the stored envelope.

int
availableAtForOutbox(string|null $queue, int|null $deliverAt)

Determine when a stored message may first be published.

Details

at line 32
protected bool shouldDispatchViaOutbox(object|string $job)

Determine whether the job selects outbox delivery.

Parameters

object|string $job

Return Value

bool

at line 44
protected mixed withOutboxForwarding(array|null $forwarded, callable $callback)

Run a child attempt or handler with its own forwarding context.

Parameters

array|null $forwarded
callable $callback

Return Value

mixed

at line 68
protected bool shouldStageViaOutbox(object|string $job)

Determine whether this driver needs SQL staging for the selected job.

Parameters

object|string $job

Return Value

bool

at line 76
protected string|null resolveOutboxCommitConnection(DatabaseTransactionsManager $transactions, object|string $job)

Select an explicit transaction for a local or failover after-commit fallback.

Parameters

DatabaseTransactionsManager $transactions
object|string $job

Return Value

string|null

at line 97
protected string enqueueViaOutbox(object|string $job, string $payload, string|null $queue, DateInterval|DateTimeInterface|int|null $delay)

Stage a single job through its normal guarded enqueue lifecycle.

Parameters

object|string $job
string $payload
string|null $queue
DateInterval|DateTimeInterface|int|null $delay

Return Value

string

at line 124
protected array stageOutboxJobs(array $jobs, mixed $data, string|null $queue)

Stage selected jobs in owner groups and return the direct remainder.

Parameters

array $jobs
mixed $data
string|null $queue

Return Value

array

at line 207
protected array prepareOutboxRow(object|string $job, string $payload, string|null $queue, DateInterval|DateTimeInterface|int|null $delay)

Build a byte-preserving row from a finalized payload.

Parameters

object|string $job
string $payload
string|null $queue
DateInterval|DateTimeInterface|int|null $delay

Return Value

array

at line 245
protected string|null resolveOutboxQueue(string|null $queue)

Expand the logical destination without applying publication-time forwarding.

Parameters

string|null $queue

Return Value

string|null

at line 253
protected string preparePayloadForOutbox(object|string $job, string $payload)

Add metadata required while the original job is still available.

Parameters

object|string $job
string $payload

Return Value

string

at line 261
protected array prepareOutboxOptions(object|string $job, string|null $queue, string $payload)

Capture transport options that cannot be recovered from the stored envelope.

Parameters

object|string $job
string|null $queue
string $payload

Return Value

array

at line 269
protected int availableAtForOutbox(string|null $queue, int|null $deliverAt)

Determine when a stored message may first be published.

Parameters

string|null $queue
int|null $deliverAt

Return Value

int