IDurableQueueCommandCodec<T>

1. Documentation
2. API reference
3. Microsoft.Orleans.Journaling
4. IDurableQueueCommandCodec<T>

interface

Namespace: Orleans.Journaling

NuGetMarkdown

Serializes one durable queue command and applies one decoded command.

public interface IDurableQueueCommandCodec<T>

Methods

• Apply(JournalBufferReader, IDurableQueueCommandHandler<T>)Reads one encoded command and applies it to consumer.
• WriteClear(JournalStreamWriter)Writes a clear command.
• WriteDequeue(JournalStreamWriter)Writes a dequeue command.
• WriteEnqueue(T, JournalStreamWriter)Writes an enqueue command.
• WriteSnapshot(IReadOnlyCollection<T>, JournalStreamWriter)Writes a snapshot command, deriving the item count from items.