MessageAdapter

MessageAdapter

protected MessageAdapter(IdGenerator transactionIdGenerator)

messageAdapter = MessageAdapter(transactionIdGenerator)

Inicializar MessageAdapter.

transactionIdGenerator

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

AssociatedBoards

public virtual string[] AssociatedBoards { get; }

value = messageAdapter.AssociatedBoards

O adaptador só pode processar a subscrição com instrumentos associados à placa especificada.

CandlesBuildFrom

public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }

value = messageAdapter.CandlesBuildFrom

Possíveis opções para construção de velas.

Categories

public virtual MessageAdapterCategories Categories { get; }

value = messageAdapter.Categories

Categorias de adaptadores de mensagens.

CheckTimeFrameByRequest

public virtual bool CheckTimeFrameByRequest { get; }

value = messageAdapter.CheckTimeFrameByRequest

Verifique o prazo possível mediante pedido.

DisconnectTimeout

public virtual TimeSpan DisconnectTimeout { get; }

value = messageAdapter.DisconnectTimeout

Obtém o tempo para esperar por uma graciosa desconexão.

EnqueueSubscriptions

public virtual bool EnqueueSubscriptions { get; set; }

value = messageAdapter.EnqueueSubscriptions
messageAdapter.EnqueueSubscriptions = value

Increva as assinaturas.

ExtraSetup

public virtual bool ExtraSetup { get; }

value = messageAdapter.ExtraSetup

O adaptador requer uma configuração extra.

FaultDelay

public TimeSpan FaultDelay { get; set; }

value = messageAdapter.FaultDelay
messageAdapter.FaultDelay = value

Obtém ou define o atraso aplicado entre iterações com defeito.

FeatureName

public virtual string FeatureName { get; }

value = messageAdapter.FeatureName

Nome da peça.

FileSystem

public IFileSystem FileSystem { get; set; }

value = messageAdapter.FileSystem
messageAdapter.FileSystem = value

IFileSystem

HeartbeatBeforeConnect

public virtual bool HeartbeatBeforeConnect { get; }

value = messageAdapter.HeartbeatBeforeConnect

Comece a enviar TimeMessage antes da ligação estabelecida.

HeartbeatInterval

public TimeSpan HeartbeatInterval { get; set; }

value = messageAdapter.HeartbeatInterval
messageAdapter.HeartbeatInterval = value

Intervalo de verificação do servidor para rastrear a conexão viva. O valor é Zero desligado de rastreamento.

Icon

public virtual Uri Icon { get; }

value = messageAdapter.Icon

Ícone.

IsAutoReplyOnTransactonalUnsubscription

public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }

value = messageAdapter.IsAutoReplyOnTransactonalUnsubscription

Enviar resposta automática para OrderStatusMessage e PortfolioLookupMessagenunscribes.

IsFullCandlesOnly

public virtual bool IsFullCandlesOnly { get; }

value = messageAdapter.IsFullCandlesOnly

Traduz CandleMessage como apenas completamente preenchido.

IsNativeIdentifiers

public virtual bool IsNativeIdentifiers { get; }

value = messageAdapter.IsNativeIdentifiers

Identificar o instrumento financeiro nas mensagens por identificador nativo.

IsNativeIdentifiersPersistable

public virtual bool IsNativeIdentifiersPersistable { get; }

value = messageAdapter.IsNativeIdentifiersPersistable

O identificador nativo pode ser armazenado.

IsPositionsEmulationRequired

public virtual bool? IsPositionsEmulationRequired { get; }

value = messageAdapter.IsPositionsEmulationRequired

Emulação necessária do adaptador PositionChangeMessage.

IsReplaceCommandEditCurrent

public virtual bool IsReplaceCommandEditCurrent { get; }

value = messageAdapter.IsReplaceCommandEditCurrent

É o comando OrderReplaceMessage editar uma ordem atual.

IsSecurityNewsOnly

public virtual bool IsSecurityNewsOnly { get; }

value = messageAdapter.IsSecurityNewsOnly

Adaptador fornece notícias relacionadas com instrumento financeiro especificado.

IsSupportExecutionsPnL

public virtual bool IsSupportExecutionsPnL { get; }

value = messageAdapter.IsSupportExecutionsPnL

O adaptador preenche PnL.

IsSupportOrderBookIncrements

public virtual bool IsSupportOrderBookIncrements { get; }

value = messageAdapter.IsSupportOrderBookIncrements

Adaptador traduz livros de ordem incremental.

IsSupportSubscriptions

public virtual bool IsSupportSubscriptions { get; }

value = messageAdapter.IsSupportSubscriptions

Apoie quaisquer assinaturas (fatos, livros de encomendas, etc.).

IsSupportTransactionLog

public virtual bool IsSupportTransactionLog { get; }

value = messageAdapter.IsSupportTransactionLog

Adaptador traduz alterações de ordens na resposta de OrderStatusMessage.

IterationInterval

public virtual TimeSpan IterationInterval { get; set; }

value = messageAdapter.IterationInterval
messageAdapter.IterationInterval = value

Intervalo entre iterações.

LookupTimeout

public virtual TimeSpan? LookupTimeout { get; }

value = messageAdapter.LookupTimeout

Tempo de procura.

MaxParallelMessages

public int MaxParallelMessages { get; set; }

value = messageAdapter.MaxParallelMessages
messageAdapter.MaxParallelMessages = value

Obtém ou define o número máximo de mensagens paralelas (não- controlo) que podem ser processadas. Deve ser maior ou igual a 1.

Name

public override string Name { get; set; }

value = messageAdapter.Name
messageAdapter.Name = value

Nome.

NotSupportedResultMessages

public virtual IEnumerable<MessageTypes> NotSupportedResultMessages { get; set; }

value = messageAdapter.NotSupportedResultMessages
messageAdapter.NotSupportedResultMessages = value

Não suportado pelos tipos de mensagem de resultado do adaptador.

OrderConditionType

public virtual Type OrderConditionType { get; }

value = messageAdapter.OrderConditionType

Tipo de OrderCondition.

Platform

public Platforms Platform { get; protected set; }

value = messageAdapter.Platform
messageAdapter.Platform = value

Processo de bits, que pode executar o adaptador.

PossibleSupportedMessages

public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; set; }

value = messageAdapter.PossibleSupportedMessages
messageAdapter.PossibleSupportedMessages = value

Possíveis tipos de mensagens suportadas.

ReConnectionSettings

public ReConnectionSettings ReConnectionSettings { get; }

value = messageAdapter.ReConnectionSettings

Configurações de rastreamento de conexão IMessageAdapter com um servidor.

SecurityExtendedFields

public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }

value = messageAdapter.SecurityExtendedFields

Nomes dos campos de instrumentos financeiros estendidos em SecurityMessage.

StorageName

public virtual string StorageName { get; }

value = messageAdapter.StorageName

Nome do armazém.

SupportedInMessages

public virtual IEnumerable<MessageTypes> SupportedInMessages { get; set; }

value = messageAdapter.SupportedInMessages
messageAdapter.SupportedInMessages = value

Suportado por tipos de mensagem adaptador.

SupportedMarketDataTypes

internal IEnumerable<DataType> SupportedMarketDataTypes { get; set; }

value = messageAdapter.SupportedMarketDataTypes
messageAdapter.SupportedMarketDataTypes = value

SupportedOrderBookDepths

public virtual IEnumerable<int> SupportedOrderBookDepths { get; }

value = messageAdapter.SupportedOrderBookDepths

Opções disponíveis para MaxDepth.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = messageAdapter.TransactionIdGenerator
messageAdapter.TransactionIdGenerator = value

Gerador de ID de transação usado para roteamento interno da assinatura do filho. Deve ser mantido em sincronia com o gerador do adaptador pai.

UseInChannel

public virtual bool UseInChannel { get; }

value = messageAdapter.UseInChannel

Usar canais para as mensagens.

UseOutChannel

public virtual bool UseOutChannel { get; }

value = messageAdapter.UseOutChannel

Usar canais para mensagens de saída.

BoardLookupAsync

protected virtual ValueTask BoardLookupAsync(BoardLookupMessage lookupMsg, CancellationToken cancellationToken)

result = messageAdapter.BoardLookupAsync(lookupMsg, cancellationToken)

CancelOrderAsync

protected virtual ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)

result = messageAdapter.CancelOrderAsync(cancelMsg, cancellationToken)

CancelOrderGroupAsync

protected virtual ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)

result = messageAdapter.CancelOrderGroupAsync(cancelMsg, cancellationToken)

ChangePasswordAsync

protected virtual ValueTask ChangePasswordAsync(ChangePasswordMessage pwdMsg, CancellationToken cancellationToken)

result = messageAdapter.ChangePasswordAsync(pwdMsg, cancellationToken)

Clone

public virtual IMessageAdapter Clone()

result = messageAdapter.Clone()

Criar uma cópia de MessageAdapter.

Retorna: Entendido.

ConnectAsync

protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)

result = messageAdapter.ConnectAsync(connectMsg, cancellationToken)

CreateOrderLogMarketDepthBuilder

public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)

result = messageAdapter.CreateOrderLogMarketDepthBuilder(securityId)

Criar construtor de profundidade de mercado.

securityId

ID do instrumento financeiro.

Retorna: Ordem log para construtor de profundidade de mercado.

DisconnectAsync

protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)

result = messageAdapter.DisconnectAsync(disconnectMsg, cancellationToken)

GetSupportedMarketDataTypesAsync

public virtual IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)

result = messageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)

Seja suportado por tipos de mensagem adaptador.

securityId

SecurityId

from

Data de início para solicitação. Se , em seguida, todas as mensagens disponíveis serão devolvidos.

to

Data de fim para a solicitação. Se , então todas as mensagens disponíveis serão devolvidas.

Retorna: Suportado por tipos de dados de mercado adaptador.

InitMessageLocalTime

private void InitMessageLocalTime(Message message)

messageAdapter.InitMessageLocalTime(message)

Inicializar a mensagem de hora local.

message

Mensagem.

IsAllDownloadingSupported

public virtual bool IsAllDownloadingSupported(DataType dataType)

result = messageAdapter.IsAllDownloadingSupported(dataType)

É para os instrumentos financeiros especificados que são descarregados habilitados.

dataType

Informação do tipo de dados.

Retorna: Verificar o resultado.

IsSecurityRequired

public virtual bool IsSecurityRequired(DataType dataType)

result = messageAdapter.IsSecurityRequired(dataType)

Apoio à filtragem de assinaturas (assinatura/desassinatura para o instrumento financeiro especificado).

dataType

Informação do tipo de dados.

Retorna: Verificar o resultado.

IsSupportCandlesPriceLevels

public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)

result = messageAdapter.IsSupportCandlesPriceLevels(subscription)

Suporte a velas PriceLevels.

subscription

MarketDataMessage

Retorna: Verificar o resultado.

IsSupportCandlesUpdates

public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)

result = messageAdapter.IsSupportCandlesUpdates(subscription)

Suporte assinatura velas e atualizações ao vivo.

subscription

MarketDataMessage

Retorna: Verificar o resultado.

Load

public override void Load(SettingsStorage storage)

messageAdapter.Load(storage)

Carregar as configurações.

storage

Configuração do armazenamento.

MarketDataAsync

protected virtual ValueTask MarketDataAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.MarketDataAsync(mdMsg, cancellationToken)

OnCandlesSubscriptionAsync

protected virtual ValueTask OnCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnCandlesSubscriptionAsync(mdMsg, cancellationToken)

Lida com a solicitação de assinatura de dados de velas. Sobrescrever para fornecer implementação para processamento de assinaturas de velas. 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.

OnLevel1SubscriptionAsync

protected virtual ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.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 virtual ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.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.

OnNewsSubscriptionAsync

protected virtual ValueTask OnNewsSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnNewsSubscriptionAsync(mdMsg, cancellationToken)

Lida com a solicitação de assinatura de dados de notícias. Sobrescrever para fornecer implementação para processamento de notícias de assinatura. 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.

OnOrderLogSubscriptionAsync

protected virtual ValueTask OnOrderLogSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnOrderLogSubscriptionAsync(mdMsg, cancellationToken)

Lida com a solicitação de assinatura para os dados do log de pedidos (trades/transações). Sobrescrever para fornecer a implementação para o processamento da assinatura do log de pedidos. 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.

OnPropertyChanged

protected void OnPropertyChanged(string propertyName)

messageAdapter.OnPropertyChanged(propertyName)

Aumentar PropertyChanged event.

propertyName

O nome da propriedade que mudou.

OnSendInMessageAsync

protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.

message

Mensagem

cancellationToken

CancellationToken

Retorna: ValueTask

OnTFCandlesSubscriptionAsync

protected virtual ValueTask OnTFCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnTFCandlesSubscriptionAsync(mdMsg, cancellationToken)

Lida com a solicitação de assinatura para os dados de velas de tempo (velas de TF). Sobrescrever para fornecer implementação para o processamento de assinatura de velas de TF. 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 virtual ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.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 virtual ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)

result = messageAdapter.OrderStatusAsync(statusMsg, cancellationToken)

PortfolioLookupAsync

protected virtual ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)

result = messageAdapter.PortfolioLookupAsync(lookupMsg, cancellationToken)

RegisterOrderAsync

protected virtual ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)

result = messageAdapter.RegisterOrderAsync(regMsg, cancellationToken)

ReplaceOrderAsync

protected virtual ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)

result = messageAdapter.ReplaceOrderAsync(replaceMsg, cancellationToken)

ResetAsync

protected virtual ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)

result = messageAdapter.ResetAsync(resetMsg, cancellationToken)

Save

public override void Save(SettingsStorage storage)

messageAdapter.Save(storage)

Gravar as definições.

storage

Configuração do armazenamento.

SecurityLookupAsync

protected virtual ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)

result = messageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)

SendInMessageAsync

public virtual ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapter.SendInMessageAsync(message, cancellationToken)

Processa uma mensagem genérica de forma assíncrona.

message

A mensagem para processar.

cancellationToken

CancellationToken

SendOutConnectionStateAsync

protected ValueTask SendOutConnectionStateAsync(ConnectionStates state, CancellationToken cancellationToken)

result = messageAdapter.SendOutConnectionStateAsync(state, cancellationToken)

Enviar para CancellationToken) mensagem de estado de conexão.

state

ConnectionStates

cancellationToken

Inscrição de cancelamento.

SendOutDisconnectMessageAsync

protected ValueTask SendOutDisconnectMessageAsync(bool expected, CancellationToken cancellationToken)

result = messageAdapter.SendOutDisconnectMessageAsync(expected, cancellationToken)

Enviar para CancellationToken) mensagem de desconexão.

expected

Espera-se que desligue.

cancellationToken

Inscrição de cancelamento.

SendOutDisconnectMessageAsync

protected ValueTask SendOutDisconnectMessageAsync(Exception error, CancellationToken cancellationToken)

result = messageAdapter.SendOutDisconnectMessageAsync(error, cancellationToken)

Enviar para CancellationToken) mensagem de desconexão.

error

Informações de erro. Pode ser .

cancellationToken

Inscrição de cancelamento.

SendOutErrorAsync

protected ValueTask SendOutErrorAsync(string description, CancellationToken cancellationToken)

result = messageAdapter.SendOutErrorAsync(description, cancellationToken)

Inicialize uma nova mensagem ErrorMessage e passe-a para o método CancellationToken@).

description

Detalhes do erro.

cancellationToken

Inscrição de cancelamento.

SendOutErrorAsync

protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)

result = messageAdapter.SendOutErrorAsync(error, cancellationToken)

Inicialize uma nova mensagem ErrorMessage e passe-a para o método CancellationToken@).

error

Detalhes do erro.

cancellationToken

Inscrição de cancelamento.

SendOutMessageAsync

public virtual ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapter.SendOutMessageAsync(message, cancellationToken)

Enviar mensagem de saída (alteração de estado, ordem, etc.).

message

Mensagem.

cancellationToken

CancellationToken

SendSubscriptionFinishedAsync

protected ValueTask SendSubscriptionFinishedAsync(long originalTransactionId, CancellationToken cancellationToken, DateTime? nextFrom)

result = messageAdapter.SendSubscriptionFinishedAsync(originalTransactionId, cancellationToken, nextFrom)

Inicialize uma nova mensagem SubscriptionFinishedMessage e passe-a para o método CancellationToken@).

originalTransactionId

ID da mensagem original para a qual esta mensagem é uma resposta.

cancellationToken

Inscrição de cancelamento.

nextFrom

NextFrom.

SendSubscriptionNotSupportedAsync

protected ValueTask SendSubscriptionNotSupportedAsync(long originalTransactionId, CancellationToken cancellationToken)

result = messageAdapter.SendSubscriptionNotSupportedAsync(originalTransactionId, cancellationToken)

Inicialize uma nova mensagem SubscriptionResponseMessage e passe-a para o método CancellationToken@).

originalTransactionId

ID da mensagem original para a qual esta mensagem é uma resposta.

cancellationToken

Inscrição de cancelamento.

SendSubscriptionOnlineAsync

protected ValueTask SendSubscriptionOnlineAsync(long originalTransactionId, CancellationToken cancellationToken)

result = messageAdapter.SendSubscriptionOnlineAsync(originalTransactionId, cancellationToken)

Inicialize uma nova mensagem SubscriptionOnlineMessage e passe-a para o método CancellationToken@).

originalTransactionId

ID da mensagem original para a qual esta mensagem é uma resposta.

cancellationToken

Inscrição de cancelamento.

SendSubscriptionReplyAsync

protected ValueTask SendSubscriptionReplyAsync(long originalTransactionId, CancellationToken cancellationToken, Exception error)

result = messageAdapter.SendSubscriptionReplyAsync(originalTransactionId, cancellationToken, error)

Inicialize uma nova mensagem SubscriptionResponseMessage e passe-a para o método CancellationToken@).

originalTransactionId

ID da mensagem original para a qual esta mensagem é uma resposta.

cancellationToken

Inscrição de cancelamento.

error

Assinar ou cancelar a inscrição de informações de erro. A definir se a resposta.

SendSubscriptionResultAsync

protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)

result = messageAdapter.SendSubscriptionResultAsync(message, cancellationToken)

Inicializar uma nova mensagem SubscriptionOnlineMessage ou SubscriptionFinishedMessage@ e passá-la para o método CancellationToken).

message

Assinatura.

cancellationToken

Inscrição de cancelamento.

TimeAsync

protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)

result = messageAdapter.TimeAsync(timeMsg, cancellationToken)

ValidateSecurityId

protected virtual bool ValidateSecurityId(SecurityId secId)

result = messageAdapter.ValidateSecurityId(secId)

Validar o ID do instrumento financeiro especificado é suportado pelo adaptador e a assinatura pode ser feita.

secId

SecurityId.

Retorna: Verificar o resultado.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

messageAdapter.NewOutMessageAsync += handler

Novo evento de mensagem.