BasketMessageAdapter

BasketMessageAdapter

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

basketMessageAdapter = BasketMessageAdapter(transactionIdGenerator, candleBuilderProvider, securityAdapterProvider, portfolioAdapterProvider, buffer)

Initialisiert eine neue Instanz von 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)

Initialisiert eine neue Instanz des BasketMessageAdapter mit injizierbaren Abhängigkeiten.

Buffer

public IStorageBuffer Buffer { get; }

value = basketMessageAdapter.Buffer

Speicherpuffer.

CommissionManager

public ICommissionManager CommissionManager { get; set; }

value = basketMessageAdapter.CommissionManager
basketMessageAdapter.CommissionManager = value

Der Provisionsberechnungsmanager.

ConnectDisconnectEventOnFirstAdapter

public bool ConnectDisconnectEventOnFirstAdapter { get; set; }

value = basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter
basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter = value

Um das ConnectMessage Ereignis aufzurufen, wenn der erste Adapter eine Verbindung zu InnerAdapters herstellt.

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

Generieren Sie das Orderbuch aus Level1-Daten.

IgnoreExtraAdapters

public bool IgnoreExtraAdapters { get; set; }

value = basketMessageAdapter.IgnoreExtraAdapters
basketMessageAdapter.IgnoreExtraAdapters = value

Fügen Sie keine zusätzlichen Adapter hinzu.

InnerAdapters

public IInnerAdapterList InnerAdapters { get; }

value = basketMessageAdapter.InnerAdapters

Adapter, mit denen der Aggregator arbeitet.

IsRestoreSubscriptionOnErrorReconnect

public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }

value = basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value

Restore-Abonnement bei Reconnect.

IsSecurityNewsOnly

public bool IsSecurityNewsOnly { get; }

value = basketMessageAdapter.IsSecurityNewsOnly

Adapter liefert Nachrichten zu einem bestimmten Finanzinstrument.

IsSupportTransactionLog

public bool IsSupportTransactionLog { get; set; }

value = basketMessageAdapter.IsSupportTransactionLog
basketMessageAdapter.IsSupportTransactionLog = value

Verwenden Sie TransactionOrderingMessageAdapter.

IsTimeForwarded

public bool IsTimeForwarded { get; set; }

value = basketMessageAdapter.IsTimeForwarded
basketMessageAdapter.IsTimeForwarded = value

Pass on the TimeMessage the inner adapters send out. Off by default: a connector keeps a clock of its own, and the time an adapter reports only paces the wrappers around it. A replay of history has no clock but its adapter's.

LatencyManager

public ILatencyManager LatencyManager { get; set; }

value = basketMessageAdapter.LatencyManager
basketMessageAdapter.LatencyManager = value

Orders Registration Delay Calculation Manager.

Level1Extend

public bool Level1Extend { get; set; }

value = basketMessageAdapter.Level1Extend
basketMessageAdapter.Level1Extend = value

Verwenden Sie Level1ExtendBuilderAdapter.

MappingProvider

public ISecurityMappingStorageProvider MappingProvider { get; set; }

value = basketMessageAdapter.MappingProvider
basketMessageAdapter.MappingProvider = value

Anbieter von Speichern für die Finanzinstrumentkennung.

NativeIdStorage

public INativeIdStorageProvider NativeIdStorage { get; set; }

value = basketMessageAdapter.NativeIdStorage
basketMessageAdapter.NativeIdStorage = value

Anbieter von nativen Finanzinstrumenten

PnLManager

public IPnLManager PnLManager { get; set; }

value = basketMessageAdapter.PnLManager
basketMessageAdapter.PnLManager = value

Der Profit-Loss-Manager.

PortfolioAdapterProvider

public IPortfolioMessageAdapterProvider PortfolioAdapterProvider { get; }

value = basketMessageAdapter.PortfolioAdapterProvider

Der portfoliobasierte Nachrichtenadapter-Anbieter.

RoutingManager

public IBasketRoutingManager RoutingManager { get; }

value = basketMessageAdapter.RoutingManager

Bekommt den Routing-Manager.

SecurityAdapterProvider

public ISecurityMessageAdapterProvider SecurityAdapterProvider { get; }

value = basketMessageAdapter.SecurityAdapterProvider

Der Anbieter des Finanzinstruments basierten Nachrichtenadapters.

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

Slippage-Manager.

StorageProcessor

public IStorageProcessor StorageProcessor { get; }

value = basketMessageAdapter.StorageProcessor

Speicherprozessor.

StorageSettings

public StorageCoreSettings StorageSettings { get; }

value = basketMessageAdapter.StorageSettings

Speichereinstellungen.

SupportBuildingFromOrderLog

public bool SupportBuildingFromOrderLog { get; set; }

value = basketMessageAdapter.SupportBuildingFromOrderLog
basketMessageAdapter.SupportBuildingFromOrderLog = value

Verwenden Sie OrderLogMessageAdapter.

SupportCandlesCompression

public bool SupportCandlesCompression { get; set; }

value = basketMessageAdapter.SupportCandlesCompression
basketMessageAdapter.SupportCandlesCompression = value

Verwenden Sie CandleBuilderMessageAdapter.

SupportLookupTracking

public bool SupportLookupTracking { get; set; }

value = basketMessageAdapter.SupportLookupTracking
basketMessageAdapter.SupportLookupTracking = value

Verwenden Sie LookupTrackingMessageAdapter.

SupportOffline

public bool SupportOffline { get; set; }

value = basketMessageAdapter.SupportOffline
basketMessageAdapter.SupportOffline = value

Verwenden Sie OfflineMessageAdapter.

SupportOrderBookTruncate

public bool SupportOrderBookTruncate { get; set; }

value = basketMessageAdapter.SupportOrderBookTruncate
basketMessageAdapter.SupportOrderBookTruncate = value

Verwenden Sie OrderBookTruncateMessageAdapter.

SupportSecurityAll

public bool SupportSecurityAll { get; set; }

value = basketMessageAdapter.SupportSecurityAll
basketMessageAdapter.SupportSecurityAll = value

Verwenden Sie SubscriptionSecurityAllMessageAdapter.

SupportStorage

public bool SupportStorage { get; set; }

value = basketMessageAdapter.SupportStorage
basketMessageAdapter.SupportStorage = value

Verwenden Sie StorageMessageAdapter.

SuppressOrderBookIncrements

public bool SuppressOrderBookIncrements { get; set; }

value = basketMessageAdapter.SuppressOrderBookIncrements
basketMessageAdapter.SuppressOrderBookIncrements = value

Wenn , wird der OrderBookIncrementMessageAdapter niemals zur Pipeline hinzugefügt - selbst wenn der innere Adapter IsSupportOrderBookIncrements meldet.

SuppressReconnectingErrors

public bool SuppressReconnectingErrors { get; set; }

value = basketMessageAdapter.SuppressReconnectingErrors
basketMessageAdapter.SuppressReconnectingErrors = value

Unterdrücken Sie Wiederverbindungsfehler.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = basketMessageAdapter.TransactionIdGenerator
basketMessageAdapter.TransactionIdGenerator = value

Transaktions-ID-Generator für internes Kinderabonnement-Routing: muss synchron mit dem Generator des übergeordneten Adapters gehalten werden.

UseInChannel

public bool UseInChannel { get; set; }

value = basketMessageAdapter.UseInChannel
basketMessageAdapter.UseInChannel = value

Verwenden Sie Kanäle für in Nachrichten.

UseOutChannel

public bool UseOutChannel { get; set; }

value = basketMessageAdapter.UseOutChannel
basketMessageAdapter.UseOutChannel = value

Verwenden Sie Kanäle für unsere Nachrichten.

ApplyHeartbeat

public void ApplyHeartbeat(IMessageAdapter adapter, bool on)

basketMessageAdapter.ApplyHeartbeat(adapter, on)

Wenden Sie den Ein-/Aus-Herzschlagmodus für den angegebenen Adapter an.

CloneAsync

public ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = basketMessageAdapter.CloneAsync(cancellationToken)

Create a copy of BasketMessageAdapter.

cancellationToken

CancellationToken

Rückgabe: Copy.

DisposeManaged

protected override void DisposeManaged()

basketMessageAdapter.DisposeManaged()

Um zugewiesene Ressourcen freizugeben.

GetSortedAdapters

protected IEnumerable<IMessageAdapter> GetSortedAdapters()

result = basketMessageAdapter.GetSortedAdapters()

Um Adapter SortedAdapters zu erhalten, die nach der angegebenen Priorität sortiert sind.

LoadAsync

public override Task LoadAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = basketMessageAdapter.LoadAsync(storage, cancellationToken)

Asynchronously loads the state of the object from the specified SettingsStorage.

storage

The SettingsStorage instance from which to load the data.

cancellationToken

A token to monitor for cancellation requests.

Rückgabe: A task that represents the asynchronous load operation.

OnInnerAdapterNewOutMessage

protected virtual ValueTask OnInnerAdapterNewOutMessage(IMessageAdapter innerAdapter, Message message, CancellationToken cancellationToken)

result = basketMessageAdapter.OnInnerAdapterNewOutMessage(innerAdapter, message, cancellationToken)

Der Embedded Adapter Event Handler.

OnSendInMessageAsync

protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = basketMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Senden Sie eine Nachricht.

OnSendOutMessageAsync

protected virtual ValueTask OnSendOutMessageAsync(Message message, CancellationToken cancellationToken)

result = basketMessageAdapter.OnSendOutMessageAsync(message, cancellationToken)

Senden Sie ausgehende Nachricht und erhöhen NewOutMessageAsync @ Veranstaltung.

SaveAsync

public override Task SaveAsync(SettingsStorage storage, CancellationToken cancellationToken)

result = basketMessageAdapter.SaveAsync(storage, cancellationToken)

Asynchronously saves the state of the object to the specified SettingsStorage.

storage

The SettingsStorage instance to which to save the data.

cancellationToken

A token to monitor for cancellation requests.

Rückgabe: A task that represents the asynchronous save operation.

SendOutMessageAsync

public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)

result = basketMessageAdapter.SendOutMessageAsync(message, cancellationToken)

Senden Sie ausgehende Nachrichten (Zustandsänderung, Reihenfolge usw.).

message

Nachricht.

cancellationToken

CancellationToken

StockSharp#Messages#IMessageTransport#SendInMessageAsync(Message, CancellationToken)

TryGetAdapter

public bool TryGetAdapter(string porfolioName, IMessageAdapter adapter)

result = basketMessageAdapter.TryGetAdapter(porfolioName, adapter)

Versuchen Sie, Adapter nach Portfolioname zu finden.

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

basketMessageAdapter.NewOutMessageAsync += handler

Neues Nachrichtenereignis.