ChannelMessageAdapter

StockSharp.Messages

Nachrichtenadapter, Weiterleitung von Nachrichten über einen Transportkanal IMessageChannel.

Konstruktoren

public ChannelMessageAdapter(IMessageAdapter innerAdapter, IMessageChannel inputChannel, IMessageChannel outputChannel)

channelMessageAdapter = ChannelMessageAdapter(innerAdapter, inputChannel, outputChannel)

Initialisiert eine neue Instanz von ChannelMessageAdapter.

InputChannel

public IMessageChannel InputChannel { get; }

value = channelMessageAdapter.InputChannel

Adapter.

OutputChannel

public IMessageChannel OutputChannel { get; }

value = channelMessageAdapter.OutputChannel

Adapter.

public bool OwnInputChannel { get; set; }

value = channelMessageAdapter.OwnInputChannel
channelMessageAdapter.OwnInputChannel = value

Steuere die Lebensdauer des eingehenden Nachrichtenkanals.

public bool OwnOutputChannel { get; set; }

value = channelMessageAdapter.OwnOutputChannel
channelMessageAdapter.OwnOutputChannel = value

Kontrollieren Sie die Lebensdauer des ausgehenden Nachrichtenkanals.

Clone

public override IMessageAdapter Clone()

result = channelMessageAdapter.Clone()

Erstellen Sie eine Kopie von ChannelMessageAdapter.

Rückgabe: Kopie.

Dispose

public override void Dispose()

channelMessageAdapter.Dispose()

Entsorgt Elemente im Pool, die IDisposable implementieren.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Prozess InnerAdapter Ausgabenachricht.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Senden Sie eine Nachricht.