MessageStream
in package
FinalYes
Replay-safe receiver for repeated, ordered workflow input.
Table of Contents
Constants
- MAX_BATCH_SIZE : mixed = 100
Properties
- $name : string
- $context : WorkflowContext
Methods
- __construct() : mixed
- receive() : array<int, MessageStreamMessage>
- Wait for one message, then return a bounded currently-available batch.
- receiveOne() : MessageStreamMessage
Constants
MAX_BATCH_SIZE
public
mixed
MAX_BATCH_SIZE
= 100
Properties
$name read-only
public
string
$name
$context read-only
private
WorkflowContext
$context
Methods
__construct()
public
__construct(WorkflowContext $context, string $name) : mixed
Parameters
- $context : WorkflowContext
- $name : string
receive()
Wait for one message, then return a bounded currently-available batch.
public
receive([int $maxItems = 1 ]) : array<int, MessageStreamMessage>
Parameters
- $maxItems : int = 1
Return values
array<int, MessageStreamMessage>receiveOne()
public
receiveOne() : MessageStreamMessage