OutboxDispatcher
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.
at line 70
void
store(ConnectionInterface $connection, array $rows, array $jobs)
Store one owner group and register rollback cleanup before dispatch acceptance.