Skip to main content

​
Definition

Assembly: CloudNimble.SimpleMessageBus.Dispatch.IndexedDb.dll Namespace: CloudNimble.SimpleMessageBus.Dispatch.IndexedDb Inheritance: System.Object

​
Syntax

CloudNimble.SimpleMessageBus.Dispatch.IndexedDb.IndexedDbQueueProcessor

​
Summary

Processes queue items stored in an IndexedDB database and dispatches them to all IMessageHandlerIMessageHandlers</see> registered with the DI container.

​
Remarks

This processor is designed for Blazor WebAssembly applications where IndexedDB provides client-side persistent storage for message queuing. It uses a background processing model with a blocking collection to handle messages asynchronously while maintaining proper resource disposal.

​
Constructors

​
.ctor

​
Syntax

public IndexedDbQueueProcessor(CloudNimble.SimpleMessageBus.IndexedDb.Core.SimpleMessageBusDb database, CloudNimble.SimpleMessageBus.Dispatch.IMessageDispatcher dispatcher, Microsoft.Extensions.DependencyInjection.IServiceScopeFactory serviceScopeFactory)

​
Parameters

NameTypeDescription
databaseCloudNimble.SimpleMessageBus.IndexedDb.Core.SimpleMessageBusDb-
dispatcherCloudNimble.SimpleMessageBus.Dispatch.IMessageDispatcher-
serviceScopeFactoryMicrosoft.Extensions.DependencyInjection.IServiceScopeFactory-

​
.ctor Inherited

Inherited from object

​
Syntax

public Object()

​
Methods

​
Dispose

​
Syntax

public void Dispose()

​
Equals Inherited Virtual

Inherited from object

​
Syntax

public virtual bool Equals(object obj)

​
Parameters

NameTypeDescription
objobject?-

​
Returns

Type: bool

​
Equals Inherited

Inherited from object

​
Syntax

public static bool Equals(object objA, object objB)

​
Parameters

NameTypeDescription
objAobject?-
objBobject?-

​
Returns

Type: bool

​
GetHashCode Inherited Virtual

Inherited from object

​
Syntax

public virtual int GetHashCode()

​
Returns

Type: int

​
GetType Inherited

Inherited from object

​
Syntax

public System.Type GetType()

​
Returns

Type: System.Type

​
LoadQueueItems

​
Syntax

public System.Threading.Tasks.Task LoadQueueItems()

​
Returns

Type: System.Threading.Tasks.Task

​
MemberwiseClone Inherited

Inherited from object

​
Syntax

protected internal object MemberwiseClone()

​
Returns

Type: object

​
ReferenceEquals Inherited

Inherited from object

​
Syntax

public static bool ReferenceEquals(object objA, object objB)

​
Parameters

NameTypeDescription
objAobject?-
objBobject?-

​
Returns

Type: bool

​
Start

​
Syntax

public System.Threading.Tasks.Task Start(System.Threading.CancellationToken cancellationToken = null)

​
Parameters

NameTypeDescription
cancellationTokenSystem.Threading.CancellationToken-

​
Returns

Type: System.Threading.Tasks.Task

​
ToString Inherited Virtual

Inherited from object

​
Syntax

public virtual string ToString()

​
Returns

Type: string?
  • CloudNimble.SimpleMessageBus.Dispatch.IQueueProcessor
  • System.IDisposable