class OutboxDispatcher

Methods

__construct(DatabaseOutboxRepository $repository, ConnectionResolverInterface $resolver, DatabaseTransactionsManager $transactions)

Create a dispatcher without borrowing a database connection.

databaseFor(object|string $job)

Resolve the exact transaction owner and verify that its outbox is drainable.

void
store(ConnectionInterface $connection, array $rows, array $jobs)

Store one owner group and register rollback cleanup before dispatch acceptance.

Details

at line 19
__construct(DatabaseOutboxRepository $repository, ConnectionResolverInterface $resolver, DatabaseTransactionsManager $transactions)

Create a dispatcher without borrowing a database connection.

at line 29
ConnectionInterface databaseFor(object|string $job)

Resolve the exact transaction owner and verify that its outbox is drainable.

Parameters

object|string $job

Return Value

ConnectionInterface

at line 70
void store(ConnectionInterface $connection, array $rows, array $jobs)

Store one owner group and register rollback cleanup before dispatch acceptance.

Parameters

ConnectionInterface $connection
array $rows
array $jobs

Return Value

void