HeartbeatMessageAdapter

StockSharp.Algo

O adaptador de mensagens que controla a ligação.

Herda de: MessageAdapterWrapper

Construtores

HeartbeatMessageAdapter
public HeartbeatMessageAdapter(IMessageAdapter innerAdapter)
heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter)

Inicializa uma nova instância do HeartbeatMessageAdapter.

innerAdapter
Adaptador subjacente.
HeartbeatMessageAdapter
public HeartbeatMessageAdapter(IMessageAdapter innerAdapter, IHeartbeatManagerState state)
heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter, state)

Inicializa uma nova instância do HeartbeatMessageAdapter com estado explícito.

innerAdapter
Adaptador subjacente.
state
Armazém estatal.

Propriedades

SuppressReconnectingErrors
public bool SuppressReconnectingErrors { get; set; }
value = heartbeatMessageAdapter.SuppressReconnectingErrors
heartbeatMessageAdapter.SuppressReconnectingErrors = value

Suprimir os erros de reconexão.

Métodos

Clone
public override IMessageAdapter Clone()
result = heartbeatMessageAdapter.Clone()

Criar uma cópia de HeartbeatMessageAdapter.

Retorna: Entendido.

OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = heartbeatMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Processo InnerAdapter output message.

message
A mensagem.
cancellationToken
Inscrição de cancelamento.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = heartbeatMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.

message
Message.
cancellationToken
CancellationToken
ProcessReconnection
public ValueTask ProcessReconnection(TimeSpan diff, CancellationToken cancellationToken)
result = heartbeatMessageAdapter.ProcessReconnection(diff, cancellationToken)

Lógica de reconexão do processo.

diff
Tempo decorrido desde a última verificação.
cancellationToken
Inscrição de cancelamento.

Retorna: Tarefa.