AlertProcessingService

StockSharp.Alerts

アラート処理サービス。

継承元: BaseLogReceiver

実装: IAlertProcessingService, IAsyncPersistable, ILogSource, IDisposable

コンストラクター

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

スキーマ登録解除イベント。