ChannelMessageAdapter

StockSharp.Messages

Adaptador de mensagens, encaminhar mensagens através de um canal de transporte IMessageChannel.

Construtores

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

channelMessageAdapter = ChannelMessageAdapter(innerAdapter, inputChannel, outputChannel)

Inicializa uma nova instância do ChannelMessageAdapter.

InputChannel

public IMessageChannel InputChannel { get; }

value = channelMessageAdapter.InputChannel

Adaptador.

OutputChannel

public IMessageChannel OutputChannel { get; }

value = channelMessageAdapter.OutputChannel

Adaptador.

public bool OwnInputChannel { get; set; }

value = channelMessageAdapter.OwnInputChannel
channelMessageAdapter.OwnInputChannel = value

Controlar a vida útil do canal de mensagens recebidas.

public bool OwnOutputChannel { get; set; }

value = channelMessageAdapter.OwnOutputChannel
channelMessageAdapter.OwnOutputChannel = value

Controlar a vida útil do canal de mensagens de saída.

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = channelMessageAdapter.CloneAsync(cancellationToken)

Create a copy of ChannelMessageAdapter.

Retorna: Copy.

Dispose

public override void Dispose()

channelMessageAdapter.Dispose()

Elimina os itens na piscina que implementam IDesposable.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Processo InnerAdapter output message.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.