AlertProcessingService

AlertProcessingService

public AlertProcessingService(int maxQueue)

alertProcessingService = AlertProcessingService(maxQueue)

Инициализирует новый экземпляр AlertProcessingService.

maxQueue

Максимальная очередь для процесса.

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

Все схемы.

DisposeManaged

protected override void DisposeManaged()

alertProcessingService.DisposeManaged()

Освободите ресурсы.

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.

Возвращает: A task that represents the asynchronous load operation.

Register

public void Register(AlertSchema schema)

alertProcessingService.Register(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.

Возвращает: A task that represents the asynchronous save operation.

Registered

public event Action<AlertSchema> Registered

alertProcessingService.Registered += handler

Событие регистрации схемы.

UnRegistered

public event Action<AlertSchema> UnRegistered

alertProcessingService.UnRegistered += handler

Событие отмены регистрации схемы.