RithmicMessageAdapter
O adaptador de mensagem para o Protocolo Ritmo (protobuf/WebSocket).
Herda de: MessageAdapter
Construtores
public RithmicMessageAdapter(IdGenerator transactionIdGenerator)
rithmicMessageAdapter = RithmicMessageAdapter(transactionIdGenerator)
Inicializa uma nova instância do RithmicMessageAdapter.
- transactionIdGenerator
- Gerador de identificação de transação.
Propriedades
public SecureString Password { get; set; }
value = rithmicMessageAdapter.Password
rithmicMessageAdapter.Password = value
Senha do utilizador.
public string ServerAddress { get; set; }
value = rithmicMessageAdapter.ServerAddress
rithmicMessageAdapter.ServerAddress = value
Endereço do servidor (wss://...).
public string SystemName { get; set; }
value = rithmicMessageAdapter.SystemName
rithmicMessageAdapter.SystemName = value
Nome do sistema Ritmico.
public string UserName { get; set; }
value = rithmicMessageAdapter.UserName
rithmicMessageAdapter.UserName = value
Autenticação do utilizador.
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)
É para os instrumentos financeiros especificados que são descarregados habilitados.
- dataType
- Informação do tipo de dados.
Retorna: Verificar o resultado.
public override void Load(SettingsStorage storage)
rithmicMessageAdapter.Load(storage)
Carregar as configurações.
- storage
- Configuração do armazenamento.
protected override ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)
Lida com a solicitação de assinatura para dados de nível 1. Sobrescrever para fornecer implementação para processamento de assinatura de nível 1. A implementação padrão lança NotSupported.
- mdMsg
- Mensagem de subscrição de dados de mercado.
- cancellationToken
- Inscrição de cancelamento para cancelar a operação.
Retorna: A ValueTask representa a operação assíncrona.
protected override ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnMarketDepthSubscriptionAsync(mdMsg, cancellationToken)
Lida com a solicitação de assinatura para dados de profundidade do mercado. Sobrescrever para fornecer implementação para processamento de profundidade de mercado. A implementação padrão lança NotSupported.
- mdMsg
- Mensagem de subscrição de dados de mercado.
- cancellationToken
- Inscrição de cancelamento para cancelar a operação.
Retorna: A ValueTask representa a operação assíncrona.
protected override ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)
Lida com a solicitação de assinatura de dados de tiques. Sobreponha- se para fornecer a implementação do processamento de assinaturas de tiques. A implementação padrão lança NotSupported.
- mdMsg
- Mensagem de subscrição de dados de mercado.
- cancellationToken
- Inscrição de cancelamento para cancelar a operação.
Retorna: A ValueTask representa a operação assíncrona.
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)
Gravar as definições.
- storage
- Configuração do armazenamento.
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()
Converter para uma representação de linha.
Retorna: Desempenho de cordas.