BasketMessageAdapter

StockSharp.Algo

Adaptador-aggregador que permite operar simultáneamente múltiples adaptadores conectados a diferentes sistemas de comercio.

Hereda de: BaseLogReceiver

Implementa: IMessageAdapterWrapper, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable

Constructores

BasketMessageAdapter
public BasketMessageAdapter(IdGenerator transactionIdGenerator, CandleBuilderProvider candleBuilderProvider, ISecurityMessageAdapterProvider securityAdapterProvider, IPortfolioMessageAdapterProvider portfolioAdapterProvider, IStorageBuffer buffer)
basketMessageAdapter = BasketMessageAdapter(transactionIdGenerator, candleBuilderProvider, securityAdapterProvider, portfolioAdapterProvider, buffer)

Inicia una nueva instancia de la BasketMessageAdapter.

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)

Inicia una nueva instancia de BasketMessageAdapter@ con dependencias inyectables.

Propiedades

Buffer
public IStorageBuffer Buffer { get; }
value = basketMessageAdapter.Buffer

Buffer de almacenamiento.

CommissionManager
public ICommissionManager CommissionManager { get; set; }
value = basketMessageAdapter.CommissionManager
basketMessageAdapter.CommissionManager = value

La comisión calculando el gerente.

ConnectDisconnectEventOnFirstAdapter
public bool ConnectDisconnectEventOnFirstAdapter { get; set; }
value = basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter
basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter = value

Para llamar al evento ConnectMessage cuando el primer adaptador se conecta a InnerAdapters.

ExtendedInfoStorage
public IExtendedInfoStorage ExtendedInfoStorage { get; set; }
value = basketMessageAdapter.ExtendedInfoStorage
basketMessageAdapter.ExtendedInfoStorage = value

Almacenamiento de información extendido.

FillGapsBehaviour
public IFillGapsBehaviour FillGapsBehaviour { get; set; }
value = basketMessageAdapter.FillGapsBehaviour
basketMessageAdapter.FillGapsBehaviour = value

IFillGapsBehaviour

GenerateOrderBookFromLevel1
public bool GenerateOrderBookFromLevel1 { get; set; }
value = basketMessageAdapter.GenerateOrderBookFromLevel1
basketMessageAdapter.GenerateOrderBookFromLevel1 = value

Generar libro de pedidos de datos de nivel 1.

IgnoreExtraAdapters
public bool IgnoreExtraAdapters { get; set; }
value = basketMessageAdapter.IgnoreExtraAdapters
basketMessageAdapter.IgnoreExtraAdapters = value

No agregue adaptadores extras.

InnerAdapters
public IInnerAdapterList InnerAdapters { get; }
value = basketMessageAdapter.InnerAdapters

Adaptadores con los que opera el agregador.

IsRestoreSubscriptionOnErrorReconnect
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value

Restaurar la suscripción en la reconexión.

IsSecurityNewsOnly
public bool IsSecurityNewsOnly { get; }
value = basketMessageAdapter.IsSecurityNewsOnly

Adaptador proporciona noticias relacionadas con un instrumento financiero especificado.

IsSupportTransactionLog
public bool IsSupportTransactionLog { get; set; }
value = basketMessageAdapter.IsSupportTransactionLog
basketMessageAdapter.IsSupportTransactionLog = value

Utilice TransactionOrderingMessageAdapter@.

LatencyManager
public ILatencyManager LatencyManager { get; set; }
value = basketMessageAdapter.LatencyManager
basketMessageAdapter.LatencyManager = value

Ordena el administrador de cálculo de demoras de registro.

Level1Extend
public bool Level1Extend { get; set; }
value = basketMessageAdapter.Level1Extend
basketMessageAdapter.Level1Extend = value

Utilice Level1ExtendBuilderAdapter@.

MappingProvider
public ISecurityMappingStorageProvider MappingProvider { get; set; }
value = basketMessageAdapter.MappingProvider
basketMessageAdapter.MappingProvider = value

proveedor de almacenamiento de mapas de identificadores de instrumentos financieros.

NativeIdStorage
public INativeIdStorageProvider NativeIdStorage { get; set; }
value = basketMessageAdapter.NativeIdStorage
basketMessageAdapter.NativeIdStorage = value

instrumento financiero proveedor de almacenamiento de identificadores nativos.

PnLManager
public IPnLManager PnLManager { get; set; }
value = basketMessageAdapter.PnLManager
basketMessageAdapter.PnLManager = value

El gerente de pérdidas de ganancias.

PortfolioAdapterProvider
public IPortfolioMessageAdapterProvider PortfolioAdapterProvider { get; }
value = basketMessageAdapter.PortfolioAdapterProvider

El proveedor del adaptador de mensaje basado en cartera.

RoutingManager
public IBasketRoutingManager RoutingManager { get; }
value = basketMessageAdapter.RoutingManager

Consigue al gerente de la ruta.

SecurityAdapterProvider
public ISecurityMessageAdapterProvider SecurityAdapterProvider { get; }
value = basketMessageAdapter.SecurityAdapterProvider

El proveedor del adaptador de mensaje basado en instrumentos financieros.

SendFinishedCandlesImmediatelly
public bool SendFinishedCandlesImmediatelly { get; set; }
value = basketMessageAdapter.SendFinishedCandlesImmediatelly
basketMessageAdapter.SendFinishedCandlesImmediatelly = value

SendFinishedCandlesImmediatelly.

SlippageManager
public ISlippageManager SlippageManager { get; set; }
value = basketMessageAdapter.SlippageManager
basketMessageAdapter.SlippageManager = value

Gerente de deslizamiento.

StorageProcessor
public IStorageProcessor StorageProcessor { get; }
value = basketMessageAdapter.StorageProcessor

Procesador de almacenamiento.

StorageSettings
public StorageCoreSettings StorageSettings { get; }
value = basketMessageAdapter.StorageSettings

Ajustes de almacenamiento.

SupportBuildingFromOrderLog
public bool SupportBuildingFromOrderLog { get; set; }
value = basketMessageAdapter.SupportBuildingFromOrderLog
basketMessageAdapter.SupportBuildingFromOrderLog = value

Utilice OrderLogMessageAdapter@.

SupportCandlesCompression
public bool SupportCandlesCompression { get; set; }
value = basketMessageAdapter.SupportCandlesCompression
basketMessageAdapter.SupportCandlesCompression = value

Utilice CandleBuilderMessageAdapter@.

SupportLookupTracking
public bool SupportLookupTracking { get; set; }
value = basketMessageAdapter.SupportLookupTracking
basketMessageAdapter.SupportLookupTracking = value

Utilice LookupTrackingMessageAdapter@.

SupportOffline
public bool SupportOffline { get; set; }
value = basketMessageAdapter.SupportOffline
basketMessageAdapter.SupportOffline = value

Utilice OfflineMessageAdapter@.

SupportOrderBookTruncate
public bool SupportOrderBookTruncate { get; set; }
value = basketMessageAdapter.SupportOrderBookTruncate
basketMessageAdapter.SupportOrderBookTruncate = value

Utilice OrderBookTruncateMessageAdapter@.

SupportSecurityAll
public bool SupportSecurityAll { get; set; }
value = basketMessageAdapter.SupportSecurityAll
basketMessageAdapter.SupportSecurityAll = value

Utilice SubscriptionSecurityAllMessageAdapter@.

SupportStorage
public bool SupportStorage { get; set; }
value = basketMessageAdapter.SupportStorage
basketMessageAdapter.SupportStorage = value

Utilice StorageMessageAdapter@.

SuppressOrderBookIncrements
public bool SuppressOrderBookIncrements { get; set; }
value = basketMessageAdapter.SuppressOrderBookIncrements
basketMessageAdapter.SuppressOrderBookIncrements = value

Cuando , el OrderBookIncrementMessageAdapter@ no se añade al oleoducto, incluso cuando el adaptador interior informa IsSupportOrderBookIncrements@.

SuppressReconnectingErrors
public bool SuppressReconnectingErrors { get; set; }
value = basketMessageAdapter.SuppressReconnectingErrors
basketMessageAdapter.SuppressReconnectingErrors = value

Suppress reconnecting errors.

TransactionIdGenerator
public IdGenerator TransactionIdGenerator { get; set; }
value = basketMessageAdapter.TransactionIdGenerator
basketMessageAdapter.TransactionIdGenerator = value

Generador de id de transacción utilizado para la routa interna de suscripción de niños. Debe mantenerse en sincronía con el generador del adaptador padre.

UseInChannel
public bool UseInChannel { get; set; }
value = basketMessageAdapter.UseInChannel
basketMessageAdapter.UseInChannel = value

Utilice canales para mensajes.

UseOutChannel
public bool UseOutChannel { get; set; }
value = basketMessageAdapter.UseOutChannel
basketMessageAdapter.UseOutChannel = value

Usar canales para mensajes fuera.

Métodos

ApplyHeartbeat
public void ApplyHeartbeat(IMessageAdapter adapter, bool on)
basketMessageAdapter.ApplyHeartbeat(adapter, on)

Aplicar el modo de latidos cardíacos encendidos/ apagados para el adaptador especificado.

Clone
public IMessageAdapter Clone()
result = basketMessageAdapter.Clone()

Crear una copia de BasketMessageAdapter.

DisposeManaged
protected override void DisposeManaged()
basketMessageAdapter.DisposeManaged()

Liberar recursos asignados.

GetSortedAdapters
protected IEnumerable<IMessageAdapter> GetSortedAdapters()
result = basketMessageAdapter.GetSortedAdapters()

Para obtener adaptadores SortedAdapters@ ordenados por la prioridad especificada.

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

Ajustes de carga.

storage
Configuración de almacenamiento.
OnInnerAdapterNewOutMessage
protected virtual ValueTask OnInnerAdapterNewOutMessage(IMessageAdapter innerAdapter, Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnInnerAdapterNewOutMessage(innerAdapter, message, cancellationToken)

El manipulador de eventos de adaptador integrado.

OnSendInMessageAsync
protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Envía mensaje.

OnSendOutMessageAsync
protected virtual ValueTask OnSendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnSendOutMessageAsync(message, cancellationToken)

Enviar mensaje saliente y subir NewOutMessageAsyncevent.

Save
public override void Save(SettingsStorage storage)
basketMessageAdapter.Save(storage)

Guardar configuración.

storage
Configuración de almacenamiento.
SendOutMessageAsync
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.SendOutMessageAsync(message, cancellationToken)

Enviar mensaje saliente (cambio de estado, orden, etc.).

message
Mensaje.
cancellationToken
CancellationToken
TryGetAdapter
public bool TryGetAdapter(string porfolioName, IMessageAdapter adapter)
result = basketMessageAdapter.TryGetAdapter(porfolioName, adapter)

Trate de encontrar adaptador por nombre de cartera.

Eventos

NewOutMessageAsync
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
basketMessageAdapter.NewOutMessageAsync += handler

Nuevo evento de mensaje.