HeartbeatMessageAdapter

StockSharp.Algo

El adaptador de mensajes controlando la conexión.

Hereda de: MessageAdapterWrapper

Constructores

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

Inicia una nueva instancia de la HeartbeatMessageAdapter.

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

Inicia una nueva instancia de HeartbeatMessageAdapter con estado explícito.

innerAdapter
Adaptador subyacente.
state
Almacenamiento estatal.

Propiedades

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

Suppress reconnecting errors.

Métodos

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

Crear una copia de HeartbeatMessageAdapter.

Devuelve: Copiado.

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

Proceso InnerAdapter@ mensaje de salida.

message
El mensaje.
cancellationToken
Cancelación token.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = heartbeatMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Envía mensaje.

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

Lógica de reconexión del proceso.

diff
El tiempo pasó desde el último cheque.
cancellationToken
Cancelación token.

Devuelve: Tarea.