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.