SimpleQueueCacheCursor

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. SimpleQueueCacheCursor

class

Namespace: Orleans.Providers.Streams.Common

NuGetSourceMarkdown

Cursor into a simple queue cache.

public class SimpleQueueCacheCursor : IQueueCacheCursor, IDisposable

Constructors

• SimpleQueueCacheCursor(SimpleQueueCache, StreamId, ILogger) Cursor into a simple queue cache

Methods

• DisposePerforms application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
• 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 Records that delivery of the current event has failed
• Refresh(StreamSequenceToken) Refreshes the cache cursor. Called when new data is added into a cache.
• ToStringReturns a string that represents the current object.