SubscriptionMessageAdapter
StockSharp.Algo
Subscription Counter Adapter.
Erbt von: MessageAdapterWrapper
Konstruktoren
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter)
Initialisiert eine neue Instanz von SubscriptionMessageAdapter.
- innerAdapter
- Inner Message Adapter.
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)
Initialisiert eine neue Instanz von SubscriptionMessageAdapter mit einem benutzerdefinierten Manager.
- innerAdapter
- Inner Message Adapter.
- manager
- Subscription Manager.
Eigenschaften
IsRestoreSubscriptionOnErrorReconnect
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value
Restore-Abonnement bei Reconnect.
Methoden
Clone
public override IMessageAdapter Clone()
result = subscriptionMessageAdapter.Clone()
Erstellen Sie eine Kopie von SubscriptionMessageAdapter.
Rückgabe: Kopie.
InnerAdapterNewOutMessageAsync
protected override ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.InnerAdapterNewOutMessageAsync(message, cancellationToken)
Prozess InnerAdapter Ausgabenachricht.
- message
- Die Botschaft.
- cancellationToken
- Löschungszeichen.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)
Prozess InnerAdapter Ausgabenachricht.
- message
- Die Botschaft.
- cancellationToken
- Löschungszeichen.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
Senden Sie eine Nachricht.
- message
- Message.
- cancellationToken
- CancellationToken