JsonDurableQueueCommandCodec<T> Methods

JSON codec for durable queue journal entries.

Apply(JournalBufferReader, IDurableQueueCommandHandler<T>)

public void Apply(JournalBufferReader input, IDurableQueueCommandHandler<T> consumer)

Reads one encoded command and applies it to consumer.

public void WriteClear(JournalStreamWriter writer)

Writes a clear command.

public void WriteDequeue(JournalStreamWriter writer)

Writes a dequeue command.

public void WriteEnqueue(T item, JournalStreamWriter writer)

Writes an enqueue command.

public void WriteSnapshot(IReadOnlyCollection<T> items, JournalStreamWriter writer)

Writes a snapshot command, deriving the item count from items.