Skip to content

IQueueAdapterFactory Methods

Adapter factory. This should create an adapter from the stream provider configuration

CreateAdapter

abstract
View source
[System.Obsolete(Use the overload which accepts a CancellationToken.)]
public abstract Task<IQueueAdapter> CreateAdapter()
Creates a queue adapter.

Returns

The queue adapter

CreateAdapter(CancellationToken)

virtual
View source
public virtual Task<IQueueAdapter> CreateAdapter(CancellationToken cancellationToken)
Creates a queue adapter.

Parameters

cancellationTokenCancellationToken
The cancellation token.

Returns

The queue adapter.

GetDeliveryFailureHandler(QueueId)

abstract
public abstract Task<IStreamFailureHandler> GetDeliveryFailureHandler(QueueId queueId)
Acquire delivery failure handler for a queue

Parameters

queueIdQueueId
The queue identifier.

Returns

The stream failure handler.

GetQueueAdapterCache

abstract
public abstract IQueueAdapterCache GetQueueAdapterCache()
Creates queue message cache adapter.

Returns

The queue adapter cache.

GetStreamQueueMapper

abstract
public abstract IStreamQueueMapper GetStreamQueueMapper()
Creates a queue mapper.

Returns

The queue mapper.