* Get aggregator for a workspace (used by components that need direct access). * Returns undefined if workspace does not exist.
(workspaceId: string)
| 2219 | * Returns undefined if workspace does not exist. |
| 2220 | */ |
| 2221 | getAggregator(workspaceId: string): StreamingMessageAggregator | undefined { |
| 2222 | return this.aggregators.get(workspaceId); |
| 2223 | } |
| 2224 | |
| 2225 | /** |
| 2226 | * Clear stored abort reason so manual retries can re-enable auto-retry. |