AlertProcessingService

AlertProcessingService

public AlertProcessingService(int maxQueue)

alertProcessingService = AlertProcessingService(maxQueue)

Inicia una nueva instancia de la AlertProcessingService.

maxQueue

Max cola para el proceso.

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

Todos los esquemas.

DisposeManaged

protected override void DisposeManaged()

alertProcessingService.DisposeManaged()

Libera recursos.

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.

Devuelve: A task that represents the asynchronous load operation.

Register

public void Register(AlertSchema schema)

alertProcessingService.Register(schema)

Registre esquema.

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.

Devuelve: A task that represents the asynchronous save operation.

Registered

public event Action<AlertSchema> Registered

alertProcessingService.Registered += handler

Evento de registro de esquemas.

UnRegistered

public event Action<AlertSchema> UnRegistered

alertProcessingService.UnRegistered += handler

evento de Schema sin registrar.