BasketMessageAdapter
Adaptador-agregador que permite operar simultaneamente vários adaptadores conectados a diferentes sistemas de negociação.
Herda de: BaseLogReceiver
Implementa: IMessageAdapterWrapper, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
Construtores
public BasketMessageAdapter(IdGenerator transactionIdGenerator, CandleBuilderProvider candleBuilderProvider, ISecurityMessageAdapterProvider securityAdapterProvider, IPortfolioMessageAdapterProvider portfolioAdapterProvider, IStorageBuffer buffer)
basketMessageAdapter = BasketMessageAdapter(transactionIdGenerator, candleBuilderProvider, securityAdapterProvider, portfolioAdapterProvider, buffer)
Inicializa uma nova instância do BasketMessageAdapter.
public BasketMessageAdapter(IdGenerator transactionIdGenerator, CandleBuilderProvider candleBuilderProvider, ISecurityMessageAdapterProvider securityAdapterProvider, IPortfolioMessageAdapterProvider portfolioAdapterProvider, IStorageBuffer buffer, IAdapterWrapperPipelineBuilder pipelineBuilder, IBasketRoutingManager routingManager)
basketMessageAdapter = BasketMessageAdapter(transactionIdGenerator, candleBuilderProvider, securityAdapterProvider, portfolioAdapterProvider, buffer, pipelineBuilder, routingManager)
Inicializa uma nova instância do BasketMessageAdapter com dependências injetáveis.
Propriedades
public IStorageBuffer Buffer { get; }
value = basketMessageAdapter.Buffer
Tampão de armazenamento.
public ICommissionManager CommissionManager { get; set; }
value = basketMessageAdapter.CommissionManager
basketMessageAdapter.CommissionManager = value
O gerente de cálculo da comissão.
public bool ConnectDisconnectEventOnFirstAdapter { get; set; }
value = basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter
basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter = value
Chamar o evento ConnectMessage quando o primeiro adaptador se conecta a InnerAdapters.
public IExtendedInfoStorage ExtendedInfoStorage { get; set; }
value = basketMessageAdapter.ExtendedInfoStorage
basketMessageAdapter.ExtendedInfoStorage = value
Armazenamento de informações estendido.
public IFillGapsBehaviour FillGapsBehaviour { get; set; }
value = basketMessageAdapter.FillGapsBehaviour
basketMessageAdapter.FillGapsBehaviour = value
IFillGapsBehaviour
public bool GenerateOrderBookFromLevel1 { get; set; }
value = basketMessageAdapter.GenerateOrderBookFromLevel1
basketMessageAdapter.GenerateOrderBookFromLevel1 = value
Gere o livro de pedidos a partir de dados de Nível 1.
public bool IgnoreExtraAdapters { get; set; }
value = basketMessageAdapter.IgnoreExtraAdapters
basketMessageAdapter.IgnoreExtraAdapters = value
Não adicione adaptadores extras.
public IInnerAdapterList InnerAdapters { get; }
value = basketMessageAdapter.InnerAdapters
Adaptadores com os quais o agregador opera.
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value
Restaurar assinatura ao reconectar.
public bool IsSecurityNewsOnly { get; }
value = basketMessageAdapter.IsSecurityNewsOnly
Adaptador fornece notícias relacionadas com instrumento financeiro especificado.
public bool IsSupportTransactionLog { get; set; }
value = basketMessageAdapter.IsSupportTransactionLog
basketMessageAdapter.IsSupportTransactionLog = value
Usar TransactionOrderingMessageAdapter.
public ILatencyManager LatencyManager { get; set; }
value = basketMessageAdapter.LatencyManager
basketMessageAdapter.LatencyManager = value
Gerente de cálculo de atraso de registro de pedidos.
public bool Level1Extend { get; set; }
value = basketMessageAdapter.Level1Extend
basketMessageAdapter.Level1Extend = value
Usar Level1ExtendBuilderAdapter.
public ISecurityMappingStorageProvider MappingProvider { get; set; }
value = basketMessageAdapter.MappingProvider
basketMessageAdapter.MappingProvider = value
Identificador do instrumento financeiro que mapeia o fornecedor de armazenamento.
public INativeIdStorageProvider NativeIdStorage { get; set; }
value = basketMessageAdapter.NativeIdStorage
basketMessageAdapter.NativeIdStorage = value
O fornecedor de armazenamento de identificador nativo do instrumento financeiro.
public IPnLManager PnLManager { get; set; }
value = basketMessageAdapter.PnLManager
basketMessageAdapter.PnLManager = value
O gerente de perdas de lucro.
public IPortfolioMessageAdapterProvider PortfolioAdapterProvider { get; }
value = basketMessageAdapter.PortfolioAdapterProvider
O provedor do adaptador de mensagens baseado em portfólio.
public IBasketRoutingManager RoutingManager { get; }
value = basketMessageAdapter.RoutingManager
- Apanha o gerente de roteamento.
public ISecurityMessageAdapterProvider SecurityAdapterProvider { get; }
value = basketMessageAdapter.SecurityAdapterProvider
O fornecedor do adaptador de mensagens baseado em instrumentos financeiros.
public bool SendFinishedCandlesImmediatelly { get; set; }
value = basketMessageAdapter.SendFinishedCandlesImmediatelly
basketMessageAdapter.SendFinishedCandlesImmediatelly = value
SendFinishedCandlesImmediatelly.
public ISlippageManager SlippageManager { get; set; }
value = basketMessageAdapter.SlippageManager
basketMessageAdapter.SlippageManager = value
Gerente de escorregaduras.
public IStorageProcessor StorageProcessor { get; }
value = basketMessageAdapter.StorageProcessor
Processador de armazenamento.
public StorageCoreSettings StorageSettings { get; }
value = basketMessageAdapter.StorageSettings
Configuração do armazenamento.
public bool SupportBuildingFromOrderLog { get; set; }
value = basketMessageAdapter.SupportBuildingFromOrderLog
basketMessageAdapter.SupportBuildingFromOrderLog = value
Usar OrderLogMessageAdapter.
public bool SupportCandlesCompression { get; set; }
value = basketMessageAdapter.SupportCandlesCompression
basketMessageAdapter.SupportCandlesCompression = value
Usar CandleBuilderMessageAdapter.
public bool SupportLookupTracking { get; set; }
value = basketMessageAdapter.SupportLookupTracking
basketMessageAdapter.SupportLookupTracking = value
Usar LookupTrackingMessageAdapter.
public bool SupportOffline { get; set; }
value = basketMessageAdapter.SupportOffline
basketMessageAdapter.SupportOffline = value
Usar OfflineMessageAdapter.
public bool SupportOrderBookTruncate { get; set; }
value = basketMessageAdapter.SupportOrderBookTruncate
basketMessageAdapter.SupportOrderBookTruncate = value
Usar OrderBookTruncateMessageAdapter.
public bool SupportSecurityAll { get; set; }
value = basketMessageAdapter.SupportSecurityAll
basketMessageAdapter.SupportSecurityAll = value
Usar SubscriptionSecurityAllMessageAdapter.
public bool SupportStorage { get; set; }
value = basketMessageAdapter.SupportStorage
basketMessageAdapter.SupportStorage = value
Usar StorageMessageAdapter.
public bool SuppressOrderBookIncrements { get; set; }
value = basketMessageAdapter.SuppressOrderBookIncrements
basketMessageAdapter.SuppressOrderBookIncrements = value
Quando , o OrderBookIncrementMessageAdapter nunca é adicionado ao gasoduto — mesmo quando o adaptador interno relata IsSupportOrderBookIncrements.
public bool SuppressReconnectingErrors { get; set; }
value = basketMessageAdapter.SuppressReconnectingErrors
basketMessageAdapter.SuppressReconnectingErrors = value
Suprimir os erros de reconexão.
public IdGenerator TransactionIdGenerator { get; set; }
value = basketMessageAdapter.TransactionIdGenerator
basketMessageAdapter.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 bool UseInChannel { get; set; }
value = basketMessageAdapter.UseInChannel
basketMessageAdapter.UseInChannel = value
Usar canais para as mensagens.
public bool UseOutChannel { get; set; }
value = basketMessageAdapter.UseOutChannel
basketMessageAdapter.UseOutChannel = value
Usar canais para mensagens de saída.
Métodos
public void ApplyHeartbeat(IMessageAdapter adapter, bool on)
basketMessageAdapter.ApplyHeartbeat(adapter, on)
Aplicar o modo de batimento cardíaco ligado/desligado para o adaptador especificado.
public IMessageAdapter Clone()
result = basketMessageAdapter.Clone()
Criar uma cópia de BasketMessageAdapter.
protected override void DisposeManaged()
basketMessageAdapter.DisposeManaged()
Para liberar recursos alocados.
protected IEnumerable<IMessageAdapter> GetSortedAdapters()
result = basketMessageAdapter.GetSortedAdapters()
Para obter adaptadores SortedAdapters ordenados pela prioridade especificada.
public override void Load(SettingsStorage storage)
basketMessageAdapter.Load(storage)
Carregar as configurações.
- storage
- Configuração do armazenamento.
protected virtual ValueTask OnInnerAdapterNewOutMessage(IMessageAdapter innerAdapter, Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnInnerAdapterNewOutMessage(innerAdapter, message, cancellationToken)
O adaptador incorporado de evento.
protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
Enviar mensagem.
protected virtual ValueTask OnSendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnSendOutMessageAsync(message, cancellationToken)
Envie mensagem de saída e levante NewOutMessageAsync event.
public override void Save(SettingsStorage storage)
basketMessageAdapter.Save(storage)
Gravar as definições.
- storage
- Configuração do armazenamento.
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.SendOutMessageAsync(message, cancellationToken)
Enviar mensagem de saída (alteração de estado, ordem, etc.).
- message
- Mensagem.
- cancellationToken
- CancellationToken
public bool TryGetAdapter(string porfolioName, IMessageAdapter adapter)
result = basketMessageAdapter.TryGetAdapter(porfolioName, adapter)
Tente encontrar o adaptador pelo nome do portfólio.
Eventos
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
basketMessageAdapter.NewOutMessageAsync += handler
Novo evento de mensagem.