Connector
A classe para criar conexões com sistemas de negociação.
Herda de: BaseLogReceiver
Implementa: IConnector, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, IMarketDataProvider, ITransactionProvider, ISecurityProvider, ISecurityMessageProvider, ISubscriptionProvider, ITimeProvider, IPortfolioProvider, IPositionProvider
Construtores
public Connector(ISecurityStorage securityStorage, IPositionStorage positionStorage, IExchangeInfoProvider exchangeInfoProvider, IStorageRegistry storageRegistry, ISnapshotRegistry snapshotRegistry, IStorageBuffer buffer, bool initAdapter, bool initChannels)
connector = Connector(securityStorage, positionStorage, exchangeInfoProvider, storageRegistry, snapshotRegistry, buffer, initAdapter, initChannels)
Inicializa uma nova instância do Connector.
- securityStorage
- instrumentos financeiros meta info storage.
- positionStorage
- Armazenagem de posição.
- exchangeInfoProvider
- Bolsas e conselhos de negociação provedor.
- storageRegistry
- O armazenamento de dados do mercado.
- snapshotRegistry
- Registo de armazenamento de instantâneos.
- buffer
- Tampão de armazenamento.
- initAdapter
- Inicializar adaptador de cesta.
- initChannels
- Inicializar canais.
Propriedades
public BasketMessageAdapter Adapter { get; protected set; }
value = connector.Adapter
connector.Adapter = value
Adaptador de mensagens.
public IBasketSecurityProcessorProvider BasketSecurityProcessorProvider { get; set; }
value = connector.BasketSecurityProcessorProvider
connector.BasketSecurityProcessorProvider = value
Cesto processadores de instrumentos financeiros fornecedor.
public Subscription BoardLookup { get; }
value = connector.BoardLookup
Obtenha a subscrição global em ExchangeBoard lookup. Pode ser .
public bool CanConnect { get; }
value = connector.CanConnect
Determina que connector está pronto para estabelecer a conexão.
public bool CheckSteps { get; set; }
value = connector.CheckSteps
connector.CheckSteps = value
Verifique o preço e o volume são multiplicados para passo.
public ICommissionManager CommissionManager { get; set; }
value = connector.CommissionManager
connector.CommissionManager = value
O gerente de cálculo da comissão.
public ConnectionStates ConnectionState { get; private set; }
value = connector.ConnectionState
connector.ConnectionState = value
Estado de ligação.
public Subscription DataTypeLookup { get; }
value = connector.DataTypeLookup
Obtenha a subscrição global em DataTypeInfoMessage lookup. Pode ser .
public int ErrorCount { get; private set; }
value = connector.ErrorCount
connector.ErrorCount = value
O número de erros passados através do evento Erro.
public IEnumerable<ExchangeBoard> ExchangeBoards { get; }
value = connector.ExchangeBoards
A lista de quadros de ações.
public IExchangeInfoProvider ExchangeInfoProvider { get; }
value = connector.ExchangeInfoProvider
Bolsas e conselhos de negociação provedor.
public IMessageChannel InMessageChannel { get; protected set; }
value = connector.InMessageChannel
connector.InMessageChannel = value
Canal de mensagem de entrada.
public IMessageAdapterWrapper InnerAdapter { get; set; }
value = connector.InnerAdapter
connector.InnerAdapter = value
Adaptador de mensagens interior.
public bool IsAutoUnSubscribeOnDisconnect { get; set; }
value = connector.IsAutoUnSubscribeOnDisconnect
connector.IsAutoUnSubscribeOnDisconnect = value
Enviar cancelar a subscrição ao comando desactivar.
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }
value = connector.IsRestoreSubscriptionOnNormalReconnect
connector.IsRestoreSubscriptionOnNormalReconnect = value
Restaurar assinatura ao reconectar.
public ILatencyManager LatencyManager { get; set; }
value = connector.LatencyManager
connector.LatencyManager = value
Gerente de cálculo de atraso de registro de pedidos.
public ISet<MessageTypes> LookupMessagesOnConnect { get; }
value = connector.LookupMessagesOnConnect
public IMessageAdapter MarketDataAdapter { get; private set; }
value = connector.MarketDataAdapter
connector.MarketDataAdapter = value
Adaptador de dados de mercado.
public virtual TimeSpan MarketTimeChangedInterval { get; set; }
value = connector.MarketTimeChangedInterval
connector.MarketTimeChangedInterval = value
O TimeMessage message genering Interval. O valor por omissão é de 10 milissegundos.
public Subscription OrderLookup { get; }
value = connector.OrderLookup
Obter assinatura global em busca de Ordem. Pode ser .
public int OrdersKeepCount { get; set; }
value = connector.OrdersKeepCount
connector.OrdersKeepCount = value
O número de pedidos para armazenamento. O valor padrão é 1000. Se o valor for definido como MaxValue, então as ordens não serão apagadas. Se o valor for definido como 0, então as ordens não serão armazenadas.
public IMessageChannel OutMessageChannel { get; protected set; }
value = connector.OutMessageChannel
connector.OutMessageChannel = value
Canal de mensagens de saída.
public bool OverrideSecurityData { get; set; }
value = connector.OverrideSecurityData
connector.OverrideSecurityData = value
Substituir os dados anteriores do instrumento financeiro por novos valores.
public IPnLManager PnLManager { get; set; }
value = connector.PnLManager
connector.PnLManager = value
O gerente de perdas de lucro.
public Subscription PortfolioLookup { get; }
value = connector.PortfolioLookup
Obtenha a subscrição global no portfólio de pesquisa. Pode ser .
public virtual IEnumerable<Portfolio> Portfolios { get; }
value = connector.Portfolios
A lista de carteiras.
public IEnumerable<Position> Positions { get; }
value = connector.Positions
A lista de posições.
public IPositionStorage PositionStorage { get; }
value = connector.PositionStorage
Armazenagem de posição.
public virtual IRiskManager RiskManager { get; set; }
value = connector.RiskManager
connector.RiskManager = value
Gerente de controle de risco.
public IEnumerable<Security> Securities { get; }
value = connector.Securities
A lista de instrumentos.
public SecurityIdGenerator SecurityIdGenerator { get; set; }
value = connector.SecurityIdGenerator
connector.SecurityIdGenerator = value
O identificador do instrumento gerador ID.
public Subscription SecurityLookup { get; }
value = connector.SecurityLookup
Obter assinatura global sobre a pesquisa de instrumentos financeiros. Pode ser .
public ISecurityStorage SecurityStorage { get; }
value = connector.SecurityStorage
instrumentos financeiros meta info storage.
public ISlippageManager SlippageManager { get; set; }
value = connector.SlippageManager
connector.SlippageManager = value
Gerente de escorregaduras.
public ISnapshotRegistry SnapshotRegistry { get; private set; }
value = connector.SnapshotRegistry
connector.SnapshotRegistry = value
Registo de armazenamento de instantâneos.
public StorageMetaInfoMessageAdapter StorageAdapter { get; private set; }
value = connector.StorageAdapter
connector.StorageAdapter = value
Adaptador de armazenamento.
public IStorageRegistry StorageRegistry { get; }
value = connector.StorageRegistry
O armazenamento de dados do mercado.
public IEnumerable<Subscription> Subscriptions { get; }
value = connector.Subscriptions
A lista de assinaturas.
public ISet<Subscription> SubscriptionsOnConnect { get; }
value = connector.SubscriptionsOnConnect
Enviar assinaturas em ligação.
public bool SupportAssociatedSecurity { get; set; }
value = connector.SupportAssociatedSecurity
connector.SupportAssociatedSecurity = value
Usar AssociatedSecurityAdapter.
public bool SupportBasketSecurities { get; set; }
value = connector.SupportBasketSecurities
connector.SupportBasketSecurities = value
Usar BasketSecurityMessageAdapter.
public bool SupportFilteredMarketDepth { get; set; }
value = connector.SupportFilteredMarketDepth
connector.SupportFilteredMarketDepth = value
Usar FilteredMarketDepthAdapter.
public bool SupportLevel1DepthBuilder { get; set; }
value = connector.SupportLevel1DepthBuilder
connector.SupportLevel1DepthBuilder = value
Usar Level1DepthBuilderAdapter.
public virtual bool SupportSnapshots { get; set; }
value = connector.SupportSnapshots
connector.SupportSnapshots = value
Usar SnapshotHolderMessageAdapter.
public bool TimeChange { get; set; }
value = connector.TimeChange
connector.TimeChange = value
Incremento periodicamente MarketTimeChangedInterval valor de CurrentTime.
public IMessageAdapter TransactionAdapter { get; private set; }
value = connector.TransactionAdapter
connector.TransactionAdapter = value
Adaptador transacional.
public IdGenerator TransactionIdGenerator { get; set; }
value = connector.TransactionIdGenerator
connector.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.
public virtual bool UnsubscribeOnDisconnect { get; }
value = connector.UnsubscribeOnDisconnect
Enviar cancelar a subscrição ao desligar.
public bool UpdatePortfolioByChange { get; set; }
value = connector.UpdatePortfolioByChange
connector.UpdatePortfolioByChange = value
Para atualizar os campos do Portfólio quando aparecer a mensagem PositionChangeMessage. Por padrão, está ativado.
public bool UpdateSecurityByDefinition { get; set; }
value = connector.UpdateSecurityByDefinition
connector.UpdateSecurityByDefinition = value
Para atualizar os campos do instrumento financeiro quando aparecer a mensagem SecurityMessage. Por padrão, está ativado.
public bool UpdateSecurityByLevel1 { get; set; }
value = connector.UpdateSecurityByLevel1
connector.UpdateSecurityByLevel1 = value
Para atualizar os campos do instrumento financeiro quando aparecer a mensagem Level1ChangeMessage. Por padrão, está ativado.
public bool UpdateSecurityLastQuotes { get; set; }
value = connector.UpdateSecurityLastQuotes
connector.UpdateSecurityLastQuotes = value
Para atualizar LastTick, BestBid, BestAsk em cada atualização do livro de pedidos e/ou transações. Por padrão, está habilitado.
Métodos
public void CancelOrder(Order order)
connector.CancelOrder(order)
Cancele a ordem.
- order
- A ordem que deve ser cancelada.
public ValueTask CancelOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.CancelOrderAsync(order, cancellationToken)
Cancele a ordem de forma assíncrona.
- order
- Ordem para cancelar.
- cancellationToken
- CancellationToken
public void CancelOrders(bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType, long? transactionId)
connector.CancelOrders(isStopOrder, portfolio, direction, board, security, securityType, transactionId)
Cancela as ordens por filtro.
- isStopOrder
- , se cancelar apenas uma ordem de paragem, - se ordens regulares, - ambos.
- portfolio
- Portfólio. Se o valor for igual a , então o portfólio não corresponde ao filtro de cancelamento de pedidos.
- direction
- Se o valor for , a direção não é usada.
- board
- Placa de negociação. Se o valor é igual a , então o tabuleiro não corresponde ao filtro de cancelamento de ordens.
- security
- Instrumento. Se o valor for igual a , então o instrumento não corresponde ao filtro de cancelamento de ordens.
- securityType
- Tipo de instrumento financeiro. Se o valor for , o tipo não utiliza.
- transactionId
- Id de transação de cancelamento de pedidos.
public ValueTask CancelOrdersAsync(bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType, long? transactionId, CancellationToken cancellationToken)
result = connector.CancelOrdersAsync(isStopOrder, portfolio, direction, board, security, securityType, transactionId, cancellationToken)
Cancelar ordens por filtro assíncrono.
- isStopOrder
- , se cancelar apenas uma ordem de paragem, - se ordens regulares, - ambos.
- portfolio
- Portfólio. Se o valor for igual a , então o portfólio não corresponde ao filtro de cancelamento de pedidos.
- direction
- Se o valor for , a direção não é usada.
- board
- Placa de negociação. Se o valor é igual a , então o tabuleiro não corresponde ao filtro de cancelamento de ordens.
- security
- Instrumento. Se o valor for igual a , então o instrumento não corresponde ao filtro de cancelamento de ordens.
- securityType
- Tipo de instrumento financeiro. Se o valor for , o tipo não utiliza.
- transactionId
- Id de transação de cancelamento de pedidos.
- cancellationToken
- CancellationToken
public ValueTask ChangePasswordAsync(SecureString newPassword, CancellationToken cancellationToken)
result = connector.ChangePasswordAsync(newPassword, cancellationToken)
Mudar a senha.
- newPassword
- Nova senha.
- cancellationToken
- CancellationToken
public virtual ValueTask ClearCacheAsync(CancellationToken cancellationToken)
result = connector.ClearCacheAsync(cancellationToken)
- Limpo o esconderijo.
protected string CreateSecurityId(string secCode, string boardCode)
result = connector.CreateSecurityId(secCode, boardCode)
Gerar instrumento financeiro Id.
- secCode
- SecurityCode.
- boardCode
- BoardCode.
Retorna: Instrumento financeiro de ID.
protected override void DisposeManaged()
connector.DisposeManaged()
Para liberar recursos alocados. Em particular, para desconectar do sistema de negociação via Desconectar.
public void EditOrder(Order order, Order changes)
connector.EditOrder(order, changes)
Edite a ordem.
- order
- Ordem.
- changes
- Mudança de ordem.
public ValueTask EditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.EditOrderAsync(order, changes, cancellationToken)
Edite a ordem assincronicamente.
- order
- Ordem para editar.
- changes
- Ordem para mudar com novos valores.
- cancellationToken
- CancellationToken
public IEnumerable<Level1Fields> GetLevel1Fields(Security security)
result = connector.GetLevel1Fields(security)
Para obter um conjunto de campos disponíveis Level1Campos, para os quais existem dados de mercado para o instrumento.
- security
- Instrumento financeiro.
Retorna: Campos possíveis.
public Portfolio GetPortfolio(string name)
result = connector.GetPortfolio(name)
Para obter o portfólio pelo nome de código.
- name
- Nome de código da carteira.
Retorna: O portfólio obtido. Se não houver portfólio por critérios determinados, é devolvido.
public Position GetPosition(Portfolio portfolio, Security security, string strategyId, Sides? side, string clientCode, string depoName, TPlusLimits? limitType)
result = connector.GetPosition(portfolio, security, strategyId, side, clientCode, depoName, limitType)
Para obter a posição por portfólio e instrumento.
- portfolio
- A carteira em que a posição deve ser encontrada.
- security
- O instrumento sobre o qual a posição deve ser encontrada.
- strategyId
- ID de estratégia.
- side
- Lado.
- clientCode
- O código do cliente.
- depoName
- O nome do depositário onde o stock está localizado fisicamente. Por padrão, é passado um texto vazio, o que significa a posição total por todos os depositários.
- limitType
- Limit type for Т+ market.
Retorna: Posição.
public Security GetSecurity(SecurityId securityId)
result = connector.GetSecurity(securityId)
Obter instrumento financeiro pelo identificador.
- securityId
- ID do instrumento financeiro.
Retorna: Instrumento financeiro.
private ValueTask<Security> GetSecurityAsync(SecurityId id, Func<Security, bool> changeSecurity, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(id, changeSecurity, cancellationToken)
Para obter o instrumento pelo código.
- id
- ID do instrumento financeiro.
- changeSecurity
- O manipulador que muda o instrumento. Ele retorna se o instrumento foi alterado e o SecurityReceived deve ser chamado.
- cancellationToken
- CancellationToken
Retorna: Instrumento financeiro.
public ValueTask<Security> GetSecurityAsync(SecurityId securityId, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(securityId, cancellationToken)
Obter instrumento financeiro pelo identificador.
- securityId
- ID do instrumento financeiro.
- cancellationToken
- CancellationToken
Retorna: Instrumento financeiro.
public SecurityId GetSecurityId(Security security)
result = connector.GetSecurityId(security)
Obter SecurityId.
- security
- Instrumento financeiro.
Retorna: ID do instrumento financeiro.
public object GetSecurityValue(Security security, Level1Fields field)
result = connector.GetSecurityValue(security, field)
Para obter o valor dos dados de mercado para o instrumento.
- security
- Instrumento financeiro.
- field
- Campo de dados de mercado.
Retorna: O valor do campo. Se não houver dados, o valor será devolvido.
private ValueTask InitNewOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.InitNewOrderAsync(order, cancellationToken)
Inicializar ordem de registro (id de transação, etc.).
- order
- Nova ordem.
- cancellationToken
- CancellationToken
public bool? IsOrderEditable(Order order)
result = connector.IsOrderEditable(order)
Determina que a ordem especificada pode ser editada por Ordem).
- order
- Ordem.
Retorna: se a ordem for editável, a ordem não pode ser alterada, significa nenhuma informação.
public bool? IsOrderReplaceable(Order order)
result = connector.IsOrderReplaceable(order)
Determina que a ordem especificada pode ser substituída por Ordem).
- order
- Ordem.
Retorna: Se a ordem for substituível, a ordem não pode ser substituída, significa que não há informação.
public override void Load(SettingsStorage storage)
connector.Load(storage)
Carregar as configurações.
- storage
- Configuração do armazenamento.
public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
result = connector.LookupByIdAsync(id, cancellationToken)
Para obter o instrumento pelo identificador.
- id
- ID do instrumento financeiro.
- cancellationToken
- CancellationToken
Retorna: O instrumento obtido. Se não houver instrumento por critérios, é devolvido.
public Portfolio LookupByPortfolioName(string name)
result = connector.LookupByPortfolioName(name)
Para obter o portfólio pelo nome de código.
- name
- Nome de código da carteira.
Retorna: O portfólio obtido. Se não houver portfólio por critérios determinados, é devolvido.
protected ValueTask OnCancelOrderAsync(Order order, long transactionId, CancellationToken cancellationToken)
result = connector.OnCancelOrderAsync(order, transactionId, cancellationToken)
Cancele a ordem.
- order
- Ordem para cancelar.
- transactionId
- Id de transação de cancelamento de pedidos.
- cancellationToken
- CancellationToken
protected ValueTask OnCancelOrdersAsync(long transactionId, CancellationToken cancellationToken, bool? isStopOrder, Portfolio portfolio, Sides? direction, ExchangeBoard board, Security security, SecurityTypes? securityType)
result = connector.OnCancelOrdersAsync(transactionId, cancellationToken, isStopOrder, portfolio, direction, board, security, securityType)
Cancela as ordens por filtro.
- transactionId
- Id de transação de cancelamento de pedidos.
- cancellationToken
- Inscrição de cancelamento.
- isStopOrder
- , se cancelar apenas uma ordem de paragem, - se ordens regulares, - ambos.
- portfolio
- Portfólio. Se o valor for igual a , então o portfólio não corresponde ao filtro de cancelamento de pedidos.
- direction
- Se o valor for , a direção não é usada.
- board
- Placa de negociação. Se o valor é igual a , então o tabuleiro não corresponde ao filtro de cancelamento de ordens.
- security
- Instrumento. Se o valor for igual a , então o instrumento não corresponde ao filtro de cancelamento de ordens.
- securityType
- Tipo de instrumento financeiro. Se o valor for , o tipo não utiliza.
protected virtual ValueTask OnConnectAsync(CancellationToken cancellationToken)
result = connector.OnConnectAsync(cancellationToken)
Conecte-se ao sistema de negociação.
protected virtual ValueTask OnDisconnectAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectAsync(cancellationToken)
Desligar do sistema de negociação.
protected ValueTask OnEditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.OnEditOrderAsync(order, changes, cancellationToken)
Edite a ordem.
- order
- Ordem.
- changes
- Mudança de ordem.
- cancellationToken
- CancellationToken
protected virtual ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)
result = connector.OnProcessMessage(message, cancellationToken)
Mensagem de processo.
- message
- Mensagem.
- cancellationToken
- CancellationToken
protected ValueTask OnRegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.OnRegisterOrderAsync(order, cancellationToken)
Registre nova ordem.
- order
- Dados do registo.
- cancellationToken
- CancellationToken
protected ValueTask OnReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.OnReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Registre novamente a ordem.
- oldOrder
- Cancelando ordem.
- newOrder
- Nova ordem para se registar.
- cancellationToken
- CancellationToken
private void RaiseConnected()
connector.RaiseConnected()
Para chamar o evento Conectado.
private void RaiseConnectedEx(IMessageAdapter adapter)
connector.RaiseConnectedEx(adapter)
Chamar o evento ConnectedEx.
- adapter
- Adaptador, evento iniciado.
private void RaiseConnectionError(Exception exception)
connector.RaiseConnectionError(exception)
Chamar o evento ConnectionError.
- exception
- Ligação de erro.
private void RaiseConnectionErrorEx(IMessageAdapter adapter, Exception exception)
connector.RaiseConnectionErrorEx(adapter, exception)
Chamar o evento ConnectionErrorEx.
- adapter
- Adaptador, evento iniciado.
- exception
- Ligação de erro.
private void RaiseCurrentTimeChanged(TimeSpan diff)
connector.RaiseCurrentTimeChanged(diff)
Chamar o evento CurrentTimeChanged.
- diff
- A diferença no tempo desde a última chamada do evento. A primeira vez que o evento passa o valor Zero.
private void RaiseDisconnected()
connector.RaiseDisconnected()
Para chamar o evento Desligado.
private void RaiseDisconnectedEx(IMessageAdapter adapter)
connector.RaiseDisconnectedEx(adapter)
Chamar o evento DisconnectedEx.
- adapter
- Adaptador, evento iniciado.
protected void RaiseError(Exception exception)
connector.RaiseError(exception)
Para chamar o evento de erro.
- exception
- Erro de processamento de dados.
private void RaiseLookupPortfoliosResult(PortfolioLookupMessage message, Exception error, Portfolio[] newPortfolios)
connector.RaiseLookupPortfoliosResult(message, error, newPortfolios)
Chamar o evento LookupPortfoliosResult.
- message
- Mensagem.
- error
- Um erro na operação de pesquisa. O valor será se a operação for concluída com sucesso.
- newPortfolios
- Encontrei carteiras.
private void RaiseLookupSecuritiesResult(SecurityLookupMessage message, Exception error, Security[] newSecurities)
connector.RaiseLookupSecuritiesResult(message, error, newSecurities)
Chamar o evento LookupSecuritiesResult.
- message
- Mensagem.
- error
- Um erro na operação de pesquisa. O valor será se a operação for concluída com sucesso.
- newSecurities
- Encontrei instrumentos.
protected virtual void RaiseSubscriptionFailed(Subscription subscription, Exception error, bool isSubscribe)
connector.RaiseSubscriptionFailed(subscription, error, isSubscribe)
public void RegisterOrder(Order order)
connector.RegisterOrder(order)
Registre nova ordem.
- order
- Dados do registo.
public ValueTask RegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.RegisterOrderAsync(order, cancellationToken)
Registre nova ordem assíncrona.
- order
- Dados do registo.
- cancellationToken
- CancellationToken
public void ReRegisterOrder(Order oldOrder, Order newOrder)
connector.ReRegisterOrder(oldOrder, newOrder)
Registre novamente a ordem.
- oldOrder
- Cancelando ordem.
- newOrder
- Nova ordem para se registar.
public ValueTask ReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.ReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Registre novamente a ordem assincronicamente.
- oldOrder
- Cancelando ordem.
- newOrder
- Nova ordem para se registar.
- cancellationToken
- CancellationToken
public override void Save(SettingsStorage storage)
connector.Save(storage)
Gravar as definições.
- storage
- Configuração do armazenamento.
public void SendInMessage(Message message)
connector.SendInMessage(message)
Enviar uma mensagem do módulo servidor para clientes conectados.
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendInMessageAsync(message, cancellationToken)
Processa uma mensagem genérica de forma assíncrona.
- message
- A mensagem para processar.
- cancellationToken
- CancellationToken
public void SendOutError(Exception error)
connector.SendOutError(error)
Enviar mensagem de erro.
- error
- Detalhes do erro.
public ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = connector.SendOutErrorAsync(error, cancellationToken)
Enviar mensagem de erro.
- error
- Detalhes do erro.
- cancellationToken
- CancellationToken
public void SendOutMessage(Message message)
connector.SendOutMessage(message)
Envie mensagem de saída.
- message
- Mensagem.
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendOutMessageAsync(message, cancellationToken)
Enviar mensagem de saída (alteração de estado, ordem, etc.).
- message
- Mensagem.
- cancellationToken
- CancellationToken
public void Subscribe(Subscription subscription)
connector.Subscribe(subscription)
Assina.
- subscription
- Assinatura.
public void UnSubscribe(Subscription subscription)
connector.UnSubscribe(subscription)
Cancelar a inscrição.
- subscription
- Assinatura.
Eventos
public event Action<Subscription, ExchangeBoard> BoardReceived
connector.BoardReceived += handler
ExchangeBoard recebido.
public event Action<Subscription, ICandleMessage> CandleReceived
connector.CandleReceived += handler
ICandleMessage recebido.
public event Action<long, Exception> ChangePasswordResult
connector.ChangePasswordResult += handler
Alterar o resultado da senha.
public event Action<IMessageAdapter> ConnectedEx
connector.ConnectedEx += handler
Ligado.
public event Action<Exception> ConnectionError
connector.ConnectionError += handler
Erro de conexão (por exemplo, a conexão foi interrompida pelo servidor).
public event Action<IMessageAdapter, Exception> ConnectionErrorEx
connector.ConnectionErrorEx += handler
Erro de conexão (por exemplo, a conexão foi interrompida pelo servidor).
public event Action<IMessageAdapter> ConnectionLost
connector.ConnectionLost += handler
Ligação perdida.
public event Action<IMessageAdapter> ConnectionRestored
connector.ConnectionRestored += handler
Ligação restaurada.
public event Action<TimeSpan> CurrentTimeChanged
connector.CurrentTimeChanged += handler
O tempo de servidor mudou CurrentTime. Passou a diferença de tempo desde a última chamada do evento. A primeira vez que o evento passa o valor Zero.
public event Action<Subscription, DataType> DataTypeReceived
connector.DataTypeReceived += handler
DataType recebido.
public event Action<IMessageAdapter> DisconnectedEx
connector.DisconnectedEx += handler
Desligado.
public event Action<Subscription, Level1ChangeMessage> Level1Received
connector.Level1Received += handler
Level1ChangeMessage recebido.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult
connector.LookupPortfoliosResult += handler
Resultado da pesquisa PortfolioLookupMessage recebido.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult2
connector.LookupPortfoliosResult2 += handler
Resultado da pesquisa PortfolioLookupMessage recebido.
public event Action<SecurityLookupMessage, IEnumerable<Security>, Exception> LookupSecuritiesResult
connector.LookupSecuritiesResult += handler
Resultado da pesquisa SecurityLookupMessage recebido.
public event Action<SecurityLookupMessage, IEnumerable<Security>, IEnumerable<Security>, Exception> LookupSecuritiesResult2
connector.LookupSecuritiesResult2 += handler
Resultado da pesquisa SecurityLookupMessage recebido.
public event Action<long> MassOrderCanceled
connector.MassOrderCanceled += handler
evento de cancelamento de encomendas em massa.
public event Action<long, DateTime> MassOrderCanceled2
connector.MassOrderCanceled2 += handler
evento de cancelamento de encomendas em massa.
public event Action<long, Exception> MassOrderCancelFailed
connector.MassOrderCancelFailed += handler
Erros de cancelamento de ordem em massa.
public event Action<long, Exception, DateTime> MassOrderCancelFailed2
connector.MassOrderCancelFailed2 += handler
Erros de cancelamento de ordem em massa.
public event Action<MyTrade> NewMyTrade
connector.NewMyTrade += handler
Comércio próprio recebido.
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
connector.NewOutMessageAsync += handler
Novo evento de mensagem.
public event Action<Portfolio> NewPortfolio
connector.NewPortfolio += handler
Nova carteira recebida.
public event Action<Position> NewPosition
connector.NewPosition += handler
Nova posição recebida.
public event Action<Subscription, News> NewsReceived
connector.NewsReceived += handler
Notícias recebidas.
public event Action<Subscription, IOrderBookMessage> OrderBookReceived
connector.OrderBookReceived += handler
IOrderBookMessage recebido.
public event Action<OrderFail> OrderCancelFailed
connector.OrderCancelFailed += handler
Evento de erro de cancelamento de pedido.
public event Action<Subscription, OrderFail> OrderCancelFailReceived
connector.OrderCancelFailReceived += handler
OrderFail cancelamento evento.
public event Action<Order> OrderChanged
connector.OrderChanged += handler
Ordem alterada (cancelada, combinada).
public event Action<long, Order> OrderEdited
connector.OrderEdited += handler
Ordem) resultado de evento.
public event Action<long, OrderFail> OrderEditFailed
connector.OrderEditFailed += handler
Ordem) erro resultado evento.
public event Action<Subscription, OrderFail> OrderEditFailReceived
connector.OrderEditFailReceived += handler
OrderFail edition event.
public event Action<Subscription, IOrderLogMessage> OrderLogReceived
connector.OrderLogReceived += handler
IOrderLogMessage recebido.
public event Action<Subscription, Order> OrderReceived
connector.OrderReceived += handler
Ordem recebida.
public event Action<OrderFail> OrderRegisterFailed
connector.OrderRegisterFailed += handler
Evento de erro de registro de encomenda.
public event Action<Subscription, OrderFail> OrderRegisterFailReceived
connector.OrderRegisterFailReceived += handler
OrderFail inscription event.
public event Action<Subscription, MyTrade> OwnTradeReceived
connector.OwnTradeReceived += handler
MyTrade recebido.
public event Action<Portfolio> PortfolioChanged
connector.PortfolioChanged += handler
A carteira mudou.
public event Action<Subscription, Portfolio> PortfolioReceived
connector.PortfolioReceived += handler
Portfólio recebido.
public event Action<Position> PositionChanged
connector.PositionChanged += handler
A posição mudou.
public event Action<Subscription, Position> PositionReceived
connector.PositionReceived += handler
Posição recebida.
public event Action<Subscription, Security> SecurityReceived
connector.SecurityReceived += handler
Instrumento financeiro recebido.
public event Action<Subscription, Exception, bool> SubscriptionFailed
connector.SubscriptionFailed += handler
A assinatura falhou.
public event Action<Subscription> SubscriptionOnline
connector.SubscriptionOnline += handler
A assinatura está online.
public event Action<Subscription, object> SubscriptionReceived
connector.SubscriptionReceived += handler
Valor recebido.
public event Action<Subscription> SubscriptionStarted
connector.SubscriptionStarted += handler
A assinatura está iniciada.
public event Action<Subscription, Exception> SubscriptionStopped
connector.SubscriptionStopped += handler
A assinatura está interrompida.
public event Action<Subscription, ITickTradeMessage> TickTradeReceived
connector.TickTradeReceived += handler
ITickTradeMessage recebido.
public event Action<Security, IEnumerable<KeyValuePair<Level1Fields, object>>, DateTime, DateTime> ValuesChanged
connector.ValuesChanged += handler
O instrumento financeiro foi alterado.