GeneratorAdapterFactory Methods

Adapter factory for stream generator stream provider. This factory acts as the adapter and the adapter factory. It creates receivers that use configurable generator to generate event streams, rather than reading them from storage.

Create(IServiceProvider, string)

static

View source

public static GeneratorAdapterFactory Create(IServiceProvider services, string name)

Creates a new GeneratorAdapterFactory instance.

Parameters

servicesIServiceProvider: The services.
namestring: The provider name.

Returns

The newly created GeneratorAdapterFactory 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.

ExecuteCommand(int, object)

View source

public Task<object> ExecuteCommand(int command, object arg)

A function to execute a control command.

Parameters

commandint: A serial number of the command.
argobject: An opaque command argument.

Returns

The value returned from the command handler.

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 the factory.

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.