ConcurrencyHandler
in
Table of Contents
Methods
- process() : void
- Process an incoming message, applying the concurrency strategy.
Methods
process()
Process an incoming message, applying the concurrency strategy.
public
process(Adapter $adapter, string $threadId, Message $message, callable $processCallback[, ServerRequestInterface|null $request = null ]) : void
Parameters
- $adapter : Adapter
-
The platform adapter
- $threadId : string
-
The canonical thread ID
- $message : Message
-
The incoming message (post-dedup, post-middleware)
- $processCallback : callable
-
fn(Adapter, string $threadId, Message, array $skippedMessages, int $totalSinceLastHandler): void
- $request : ServerRequestInterface|null = null
-
The original PSR-7 request (for job serialization)