AzureTableStreamQueueCheckpointer.FlushAsync(CancellationToken)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. AzureTableStreamQueueCheckpointer
5. Methods
6. FlushAsync(CancellationToken)

Markdown

FlushAsync(CancellationToken)

View source

public Task FlushAsync(CancellationToken cancellationToken)

Flushes any pending checkpoint to persistent storage, ensuring the latest offset is durably saved. Called during shutdown or rebalancing to prevent message replay on restart.

Parameters

cancellationTokenCancellationToken

The cancellation token.

Returns

A System.Threading.Tasks.Task representing the flush operation.