IndexedDbQueueProcessor

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

Name	Type	Description
`database`	`CloudNimble.SimpleMessageBus.IndexedDb.Core.SimpleMessageBusDb`	-
`dispatcher`	`CloudNimble.SimpleMessageBus.Dispatch.IMessageDispatcher`	-
`serviceScopeFactory`	`Microsoft.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

Name	Type	Description
`obj`	`object?`	-

Returns

Type: bool

Equals Inherited

Inherited from object

Syntax

public static bool Equals(object objA, object objB)

Parameters

Name	Type	Description
`objA`	`object?`	-
`objB`	`object?`	-

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

Name	Type	Description
`objA`	`object?`	-
`objB`	`object?`	-

Returns

Type: bool

Start

Syntax

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

Parameters

Name	Type	Description
`cancellationToken`	`System.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

​Definition

​Syntax

​Summary

​Remarks

​Constructors

​ .ctor

​Syntax

​Parameters

​ .ctor Inherited

​Syntax

​Methods

​ Dispose

​Syntax

​ Equals Inherited Virtual

​Syntax

​Parameters

​Returns

​ Equals Inherited

​Syntax

​Parameters

​Returns

​ GetHashCode Inherited Virtual

​Syntax

​Returns

​ GetType Inherited

​Syntax

​Returns

​ LoadQueueItems

​Syntax

​Returns

​ MemberwiseClone Inherited

​Syntax

​Returns

​ ReferenceEquals Inherited

​Syntax

​Parameters

​Returns

​ Start

​Syntax

​Parameters

​Returns

​ ToString Inherited Virtual

​Syntax

​Returns

​Related APIs

Definition

Syntax

Summary

Remarks

Constructors

.ctor

Syntax

Parameters

.ctor Inherited

Syntax

Methods

Dispose

Syntax

Equals Inherited Virtual

Syntax

Parameters

Returns

Equals Inherited

Syntax

Parameters

Returns

GetHashCode Inherited Virtual

Syntax

Returns

GetType Inherited

Syntax

Returns

LoadQueueItems

Syntax

Returns

MemberwiseClone Inherited

Syntax

Returns

ReferenceEquals Inherited

Syntax

Parameters

Returns

Start

Syntax

Parameters

Returns

ToString Inherited Virtual

Syntax

Returns

Related APIs