IDurableQueueCommandCodec<T> Methods

Serializes one durable queue command and applies one decoded command.

Apply(JournalBufferReader, IDurableQueueCommandHandler<T>)

abstract

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

Reads one encoded command and applies it to consumer.

abstract

public abstract void WriteClear(JournalStreamWriter writer)

Writes a clear command.

abstract

public abstract void WriteDequeue(JournalStreamWriter writer)

Writes a dequeue command.

abstract

public abstract void WriteEnqueue(T item, JournalStreamWriter writer)

Writes an enqueue command.

abstract

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

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