Edit

Share via


SimpleQueueCacheCursor Class

Definition

Cursor into a simple queue cache.

public class SimpleQueueCacheCursor : IDisposable, Orleans.Streams.IQueueCacheCursor
type SimpleQueueCacheCursor = class
    interface IQueueCacheCursor
    interface IDisposable
Public Class SimpleQueueCacheCursor
Implements IDisposable, IQueueCacheCursor
Inheritance
SimpleQueueCacheCursor
Implements

Constructors

SimpleQueueCacheCursor(SimpleQueueCache, IStreamIdentity, ILogger)

Cursor into a simple queue cache

SimpleQueueCacheCursor(SimpleQueueCache, IStreamIdentity, Logger)

Cursor into a simple queue cache

SimpleQueueCacheCursor(SimpleQueueCache, StreamId, ILogger)

Cursor into a simple queue cache

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

Dispose(Boolean)

Clean up cache data when done

GetCurrent(Exception)

Get the current value.

MoveNext()

Move to next message in the stream. If it returns false, there are no more messages. The enumerator is still valid however and can be called again when more data has come in on this stream.

RecordDeliveryFailure()

Record that delivery of the current event has failed

Refresh(StreamSequenceToken)

Refresh that cache cursor. Called when new data is added into a cache.

ToString()

Convert object to string

Applies to