RithmicMessageAdapter
Adaptador de mensajes para el Protocolo Ritmico (protobuf/WebSocket@).
Hereda de: MessageAdapter
Constructores
public RithmicMessageAdapter(IdGenerator transactionIdGenerator)
rithmicMessageAdapter = RithmicMessageAdapter(transactionIdGenerator)
Inicia una nueva instancia de la RithmicMessageAdapter.
- transactionIdGenerator
- Generador de identificación de transacciones.
Propiedades
public SecureString Password { get; set; }
value = rithmicMessageAdapter.Password
rithmicMessageAdapter.Password = value
Contraseña de usuario.
public string ServerAddress { get; set; }
value = rithmicMessageAdapter.ServerAddress
rithmicMessageAdapter.ServerAddress = value
Dirección del servidor (wss://...).
public string SystemName { get; set; }
value = rithmicMessageAdapter.SystemName
rithmicMessageAdapter.SystemName = value
Nombre del sistema rítmico.
public string UserName { get; set; }
value = rithmicMessageAdapter.UserName
rithmicMessageAdapter.UserName = value
Acceso de usuario.
Métodos
protected override ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.CancelOrderAsync(cancelMsg, cancellationToken)
protected override ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ConnectAsync(connectMsg, cancellationToken)
protected override ValueTask DisconnectAsync(DisconnectMessage msg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.DisconnectAsync(msg, cancellationToken)
public override bool IsAllDownloadingSupported(DataType dataType)
result = rithmicMessageAdapter.IsAllDownloadingSupported(dataType)
Es para los instrumentos financieros especificados que se descargan habilitados.
- dataType
- Datos tipo info.
Devuelve: Resultado de la comprobación.
public override void Load(SettingsStorage storage)
rithmicMessageAdapter.Load(storage)
Ajustes de carga.
- storage
- Configuración de almacenamiento.
protected override ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de fichas para datos de nivel 1. Sobrescribir para proporcionar la implementación para el procesamiento de suscripción de nivel1. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected override ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnMarketDepthSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de mangos para datos de profundidad de mercado. Sobrescribir para proporcionar la implementación para el procesamiento de suscripción a profundidad de mercado. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected override ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)
Solicitud de suscripción de mangos para datos de garrapatas. Sobrescribir para proporcionar la implementación para el procesamiento de la suscripción de garrapatas. La implementación predeterminada lanza NotSupported.
- mdMsg
- Mensaje de suscripción de datos de mercado.
- cancellationToken
- Cancelación de token para cancelar la operación.
Devuelve: A ValueTask@ representante de la operación asincrónica.
protected override ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OrderStatusAsync(statusMsg, cancellationToken)
protected override ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.PortfolioLookupAsync(lookupMsg, cancellationToken)
protected override ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.RegisterOrderAsync(regMsg, cancellationToken)
protected override ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ReplaceOrderAsync(replaceMsg, cancellationToken)
protected override ValueTask ResetAsync(ResetMessage msg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ResetAsync(msg, cancellationToken)
public override void Save(SettingsStorage storage)
rithmicMessageAdapter.Save(storage)
Guardar configuración.
- storage
- Configuración de almacenamiento.
protected override ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)
protected override ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.TimeAsync(timeMsg, cancellationToken)
public override string ToString()
result = rithmicMessageAdapter.ToString()
Convertirse en una representación de línea.
Devuelve: Rendimiento de cuerda.