AlertProcessingService

AlertProcessingService

public AlertProcessingService(int maxQueue)

alertProcessingService = AlertProcessingService(maxQueue)

Initialisiert eine neue Instanz von AlertProcessingService.

maxQueue

Max Warteschlange für den Prozess.

DroppedMessages

public long DroppedMessages { get; }

value = alertProcessingService.DroppedMessages

Number of messages dropped because the processing queue was full.

Schemas

public IEnumerable<AlertSchema> Schemas { get; }

value = alertProcessingService.Schemas

Alle Schemata.

DisposeManaged

protected override void DisposeManaged()

alertProcessingService.DisposeManaged()

Ressourcen freigeben.

LoadAsync

public override Task LoadAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = alertProcessingService.LoadAsync(storage, cancellationToken)

Asynchronously loads the state of the object from the specified SettingsStorage.

storage

The SettingsStorage instance from which to load the data.

cancellationToken

A token to monitor for cancellation requests.

Rückgabe: A task that represents the asynchronous load operation.

Register

public void Register(AlertSchema schema)

alertProcessingService.Register(schema)

Registerschema.

schema

Schema.

SaveAsync

public override Task SaveAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = alertProcessingService.SaveAsync(storage, cancellationToken)

Asynchronously saves the state of the object to the specified SettingsStorage.

storage

The SettingsStorage instance to which to save the data.

cancellationToken

A token to monitor for cancellation requests.

Rückgabe: A task that represents the asynchronous save operation.

Registered

public event Action<AlertSchema> Registered

alertProcessingService.Registered += handler

Schemaregistrierungsereignis.

UnRegistered

public event Action<AlertSchema> UnRegistered

alertProcessingService.UnRegistered += handler

Schema unregistring event.