RithmicMessageAdapter

StockSharp.Rithmic

O adaptador de mensagem para o Protocolo Ritmo (protobuf/WebSocket).

Herda de: MessageAdapter

Construtores

RithmicMessageAdapter
public RithmicMessageAdapter(IdGenerator transactionIdGenerator)
rithmicMessageAdapter = RithmicMessageAdapter(transactionIdGenerator)

Inicializa uma nova instância do RithmicMessageAdapter.

transactionIdGenerator
Gerador de identificação de transação.

Propriedades

Password
public SecureString Password { get; set; }
value = rithmicMessageAdapter.Password
rithmicMessageAdapter.Password = value

Senha do utilizador.

ServerAddress
public string ServerAddress { get; set; }
value = rithmicMessageAdapter.ServerAddress
rithmicMessageAdapter.ServerAddress = value

Endereço do servidor (wss://...).

SystemName
public string SystemName { get; set; }
value = rithmicMessageAdapter.SystemName
rithmicMessageAdapter.SystemName = value

Nome do sistema Ritmico.

UserName
public string UserName { get; set; }
value = rithmicMessageAdapter.UserName
rithmicMessageAdapter.UserName = value

Autenticação do utilizador.

Métodos

CancelOrderAsync
protected override ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.CancelOrderAsync(cancelMsg, cancellationToken)
ConnectAsync
protected override ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ConnectAsync(connectMsg, cancellationToken)
DisconnectAsync
protected override ValueTask DisconnectAsync(DisconnectMessage msg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.DisconnectAsync(msg, cancellationToken)
IsAllDownloadingSupported
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.

Load
public override void Load(SettingsStorage storage)
rithmicMessageAdapter.Load(storage)

Carregar as configurações.

storage
Configuração do armazenamento.
OnLevel1SubscriptionAsync
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.

OnMarketDepthSubscriptionAsync
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.

OnTicksSubscriptionAsync
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.

OrderStatusAsync
protected override ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.OrderStatusAsync(statusMsg, cancellationToken)
PortfolioLookupAsync
protected override ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.PortfolioLookupAsync(lookupMsg, cancellationToken)
RegisterOrderAsync
protected override ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.RegisterOrderAsync(regMsg, cancellationToken)
ReplaceOrderAsync
protected override ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ReplaceOrderAsync(replaceMsg, cancellationToken)
ResetAsync
protected override ValueTask ResetAsync(ResetMessage msg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.ResetAsync(msg, cancellationToken)
Save
public override void Save(SettingsStorage storage)
rithmicMessageAdapter.Save(storage)

Gravar as definições.

storage
Configuração do armazenamento.
SecurityLookupAsync
protected override ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)
TimeAsync
protected override ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)
result = rithmicMessageAdapter.TimeAsync(timeMsg, cancellationToken)
ToString
public override string ToString()
result = rithmicMessageAdapter.ToString()

Converter para uma representação de linha.

Retorna: Desempenho de cordas.