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