Client SDKsC#Reference
Events Store
Durable events with replay — KubeMQ C# SDK reference.
Persist events with SendEventStoreAsync and replay them with SubscribeToEventsStoreAsync, configuring StartPosition and start value fields on the subscription object.
SendEventStoreAsync
Task<EventStoreResult> SendEventStoreAsync(EventStoreMessage message, CancellationToken ct = default);SubscribeToEventsStoreAsync
IAsyncEnumerable<EventStoreReceived> SubscribeToEventsStoreAsync(
EventStoreSubscription subscription, CancellationToken ct = default);EventStoreSubscription adds:
| Property | Type | Description |
|---|---|---|
StartPosition | EventStoreStartPosition | Replay start enum |
StartSequence | long? | Sequence number; required when StartPosition is StartAtSequence |
StartTime | DateTimeOffset? | Point in time; required when StartPosition is StartAtTime |
StartTimeDeltaSeconds | int? | Seconds before now; required when StartPosition is StartAtTimeDelta |
Quick Usage
await client.SendEventStoreAsync(new EventStoreMessage
{
Channel = "audit",
Body = payload,
});See Also
Was this page helpful?