MemoryAdapterFactory<TSerializer> Methods

Adapter factory for in memory stream provider. This factory acts as the adapter and the adapter factory. The events are stored in an in-memory grain that behaves as an event queue, this provider adapter is primarily used for testing

Create(IServiceProvider, string)

static

View source

public static MemoryAdapterFactory<TSerializer> Create(IServiceProvider services, string name)

Creates a new Orleans.Providers.MemoryAdapterFactory instance.

Parameters

servicesIServiceProvider: The services.
namestring: The provider name.

Returns

A mew Orleans.Providers.MemoryAdapterFactory instance.

CreateAdapter

View source

public Task<IQueueAdapter> CreateAdapter()

Creates a queue adapter.

Returns

The queue adapter

CreateQueueCache(QueueId)

View source

public IQueueCache CreateQueueCache(QueueId queueId)

Create a cache for a given queue id

Parameters

queueIdQueueId: The queue id.

Returns

The queue cache..

CreateReceiver(QueueId)

View source

public IQueueAdapterReceiver CreateReceiver(QueueId queueId)

Creates a queue receiver for the specified queueId

Parameters

queueIdQueueId: The queue identifier.

Returns

The receiver.

GetDeliveryFailureHandler(QueueId)

View source

public Task<IStreamFailureHandler> GetDeliveryFailureHandler(QueueId queueId)

Acquire delivery failure handler for a queue

Parameters

queueIdQueueId: The queue identifier.

Returns

The stream failure handler.

GetQueueAdapterCache

View source

public IQueueAdapterCache GetQueueAdapterCache()

Creates queue message cache adapter.

Returns

The queue adapter cache.

GetStreamQueueMapper

View source

public IStreamQueueMapper GetStreamQueueMapper()

Creates a queue mapper.

Returns

The queue mapper.

Init

View source

public void Init()

Initializes this instance.

QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<string, object>)

View source

public Task QueueMessageBatchAsync<T>(StreamId streamId, IEnumerable<T> events, StreamSequenceToken token, Dictionary<string, object> requestContext)

Writes a set of events to the queue as a single batch associated with the provided streamId.

Parameters

streamIdStreamId: The stream identifier.
eventsIEnumerable<T>: The events.
tokenStreamSequenceToken: The token.
requestContextDictionary<string, object>: The request context.

Returns

Task.