Connector
Die Klasse, um Verbindungen zu Handelssystemen zu schaffen.
Erbt von: BaseLogReceiver
Implementiert: IConnector, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, IMarketDataProvider, ITransactionProvider, ISecurityProvider, ISecurityMessageProvider, ISubscriptionProvider, ITimeProvider, IPortfolioProvider, IPositionProvider
Konstruktoren
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)
Initialisiert eine neue Instanz von Connector.
- securityStorage
- Meta-Info-Speicherung von Finanzinstrumenten.
- positionStorage
- Positionsspeicherung.
- exchangeInfoProvider
- Börsen und Handelsbörsen Anbieter.
- storageRegistry
- Die Speicherung von Marktdaten.
- snapshotRegistry
- Snapshot Storage Registry.
- buffer
- Speicherpuffer.
- initAdapter
- Korbadapter initialisieren.
- initChannels
- Kanäle initialisieren.
Eigenschaften
public BasketMessageAdapter Adapter { get; protected set; }
value = connector.Adapter
connector.Adapter = value
Nachrichtenadapter.
public IBasketSecurityProcessorProvider BasketSecurityProcessorProvider { get; set; }
value = connector.BasketSecurityProcessorProvider
connector.BasketSecurityProcessorProvider = value
Anbieter von Korbfinanzinstrumentenverarbeitern.
public Subscription BoardLookup { get; }
value = connector.BoardLookup
Holen Sie sich ein globales Abonnement unter ExchangeBoard Lookup. Kann sein.
public bool CanConnect { get; }
value = connector.CanConnect
Bestimmt, dass connector bereit ist, eine Verbindung herzustellen.
public bool CheckSteps { get; set; }
value = connector.CheckSteps
connector.CheckSteps = value
Überprüfen Sie Preis und Volumen, sie multiplizieren sich, um zu schreiten.
public ICommissionManager CommissionManager { get; set; }
value = connector.CommissionManager
connector.CommissionManager = value
Der Provisionsberechnungsmanager.
public ConnectionStates ConnectionState { get; private set; }
value = connector.ConnectionState
connector.ConnectionState = value
Verbindungszustand.
public Subscription DataTypeLookup { get; }
value = connector.DataTypeLookup
Holen Sie sich ein globales Abonnement unter DataTypeInfoMessage Lookup. Kann sein.
public int ErrorCount { get; private set; }
value = connector.ErrorCount
connector.ErrorCount = value
Die Anzahl der Fehler, die durch das Fehlerereignis gegangen sind.
public IEnumerable<ExchangeBoard> ExchangeBoards { get; }
value = connector.ExchangeBoards
Die Liste der Börsengremien.
public IExchangeInfoProvider ExchangeInfoProvider { get; }
value = connector.ExchangeInfoProvider
Börsen und Handelsbörsen Anbieter.
public IMessageChannel InMessageChannel { get; protected set; }
value = connector.InMessageChannel
connector.InMessageChannel = value
Einsendenachrichtenkanal.
public IMessageAdapterWrapper InnerAdapter { get; set; }
value = connector.InnerAdapter
connector.InnerAdapter = value
Inner Message Adapter.
public bool IsAutoUnSubscribeOnDisconnect { get; set; }
value = connector.IsAutoUnSubscribeOnDisconnect
connector.IsAutoUnSubscribeOnDisconnect = value
Senden Sie unsubscribe auf disconnect-Befehl.
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }
value = connector.IsRestoreSubscriptionOnNormalReconnect
connector.IsRestoreSubscriptionOnNormalReconnect = value
Restore-Abonnement bei Reconnect.
public ILatencyManager LatencyManager { get; set; }
value = connector.LatencyManager
connector.LatencyManager = value
Orders Registration Delay Calculation Manager.
public ISet<MessageTypes> LookupMessagesOnConnect { get; }
value = connector.LookupMessagesOnConnect
public IMessageAdapter MarketDataAdapter { get; private set; }
value = connector.MarketDataAdapter
connector.MarketDataAdapter = value
Marktdatenadapter.
public virtual TimeSpan MarketTimeChangedInterval { get; set; }
value = connector.MarketTimeChangedInterval
connector.MarketTimeChangedInterval = value
Die TimeMessage-Nachricht erzeugt Intervall. Der Standard ist 10 Millisekunden.
public Subscription OrderLookup { get; }
value = connector.OrderLookup
Holen Sie sich ein globales Abonnement auf Order Lookup.
public int OrdersKeepCount { get; set; }
value = connector.OrdersKeepCount
connector.OrdersKeepCount = value
Die Anzahl der Speicheraufträge ist standardmäßig 1000. Wenn der Wert auf MaxValue gesetzt ist, werden die Aufträge nicht gelöscht. Wenn der Wert auf 0 gesetzt ist, werden die Aufträge nicht gespeichert.
public IMessageChannel OutMessageChannel { get; protected set; }
value = connector.OutMessageChannel
connector.OutMessageChannel = value
ausgehender Nachrichtenkanal.
public bool OverrideSecurityData { get; set; }
value = connector.OverrideSecurityData
connector.OverrideSecurityData = value
Überschreiben Sie frühere Finanzinstrumentdaten durch neue Werte.
public IPnLManager PnLManager { get; set; }
value = connector.PnLManager
connector.PnLManager = value
Der Profit-Loss-Manager.
public Subscription PortfolioLookup { get; }
value = connector.PortfolioLookup
Holen Sie sich ein globales Abonnement für Portfolio Lookup.
public virtual IEnumerable<Portfolio> Portfolios { get; }
value = connector.Portfolios
Die Liste der Portfolios.
public IEnumerable<Position> Positions { get; }
value = connector.Positions
Die Liste der Positionen.
public IPositionStorage PositionStorage { get; }
value = connector.PositionStorage
Positionsspeicherung.
public virtual IRiskManager RiskManager { get; set; }
value = connector.RiskManager
connector.RiskManager = value
Risikokontrollmanager.
public IEnumerable<Security> Securities { get; }
value = connector.Securities
Die Liste der Instrumente.
public SecurityIdGenerator SecurityIdGenerator { get; set; }
value = connector.SecurityIdGenerator
connector.SecurityIdGenerator = value
Der Instrumentenidentifikator Id.
public Subscription SecurityLookup { get; }
value = connector.SecurityLookup
Holen Sie sich globale Abonnement auf Finanzinstrument Lookup.
public ISecurityStorage SecurityStorage { get; }
value = connector.SecurityStorage
Meta-Info-Speicherung von Finanzinstrumenten.
public ISlippageManager SlippageManager { get; set; }
value = connector.SlippageManager
connector.SlippageManager = value
Slippage-Manager.
public ISnapshotRegistry SnapshotRegistry { get; private set; }
value = connector.SnapshotRegistry
connector.SnapshotRegistry = value
Snapshot Storage Registry.
public StorageMetaInfoMessageAdapter StorageAdapter { get; private set; }
value = connector.StorageAdapter
connector.StorageAdapter = value
Speicheradapter.
public IStorageRegistry StorageRegistry { get; }
value = connector.StorageRegistry
Die Speicherung von Marktdaten.
public IEnumerable<Subscription> Subscriptions { get; }
value = connector.Subscriptions
Die Liste der Abonnements.
public ISet<Subscription> SubscriptionsOnConnect { get; }
value = connector.SubscriptionsOnConnect
Senden Sie Abonnements auf connect.
public bool SupportAssociatedSecurity { get; set; }
value = connector.SupportAssociatedSecurity
connector.SupportAssociatedSecurity = value
Verwenden Sie AssociatedSecurityAdapter.
public bool SupportBasketSecurities { get; set; }
value = connector.SupportBasketSecurities
connector.SupportBasketSecurities = value
Verwenden Sie BasketSecurityMessageAdapter.
public bool SupportFilteredMarketDepth { get; set; }
value = connector.SupportFilteredMarketDepth
connector.SupportFilteredMarketDepth = value
Verwenden Sie FilteredMarketDepthAdapter.
public bool SupportLevel1DepthBuilder { get; set; }
value = connector.SupportLevel1DepthBuilder
connector.SupportLevel1DepthBuilder = value
Verwenden Sie Level1DepthBuilderAdapter.
public virtual bool SupportSnapshots { get; set; }
value = connector.SupportSnapshots
connector.SupportSnapshots = value
Verwenden Sie SnapshotHolderMessageAdapter.
public bool TimeChange { get; set; }
value = connector.TimeChange
connector.TimeChange = value
Inkrement regelmäßig MarketTimeChangedInterval Wert von CurrentTime.
public IMessageAdapter TransactionAdapter { get; private set; }
value = connector.TransactionAdapter
connector.TransactionAdapter = value
Transaktionsadapter.
public IdGenerator TransactionIdGenerator { get; set; }
value = connector.TransactionIdGenerator
connector.TransactionIdGenerator = value
Transaktions-ID-Generator für internes Kinderabonnement-Routing: muss synchron mit dem Generator des übergeordneten Adapters gehalten werden.
public virtual bool UnsubscribeOnDisconnect { get; }
value = connector.UnsubscribeOnDisconnect
Senden Sie unsubscribe bei der Trennung.
public bool UpdatePortfolioByChange { get; set; }
value = connector.UpdatePortfolioByChange
connector.UpdatePortfolioByChange = value
So aktualisieren Sie die Portfoliofelder, wenn die PositionChangeMessage-Nachricht angezeigt wird. Standardmäßig ist dies aktiviert.
public bool UpdateSecurityByDefinition { get; set; }
value = connector.UpdateSecurityByDefinition
connector.UpdateSecurityByDefinition = value
Um die Felder für Finanzinstrumente zu aktualisieren, wenn die SecurityMessage-Nachricht angezeigt wird.
public bool UpdateSecurityByLevel1 { get; set; }
value = connector.UpdateSecurityByLevel1
connector.UpdateSecurityByLevel1 = value
Um die Felder für Finanzinstrumente zu aktualisieren, wenn die Level1ChangeMessage-Nachricht angezeigt wird.
public bool UpdateSecurityLastQuotes { get; set; }
value = connector.UpdateSecurityLastQuotes
connector.UpdateSecurityLastQuotes = value
Aktualisieren LastTick, BestBid, BestAsk bei jedem Update des Orderbuchs und / oder der Trades. Standardmäßig ist aktiviert.
Methoden
public void CancelOrder(Order order)
connector.CancelOrder(order)
Stornieren Sie die Bestellung.
- order
- Die Bestellung, die storniert werden sollte.
public ValueTask CancelOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.CancelOrderAsync(order, cancellationToken)
Stornieren Sie die Bestellung asynchron.
- order
- Anweisung zur Stornierung.
- 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)
Bestellungen per Filter stornieren.
- isStopOrder
- , wenn nur eine Stop-Orders stornieren, - wenn reguläre Bestellungen, - beides.
- portfolio
- Portfolio. Wenn der Wert gleich , dann stimmt das Portfolio nicht mit dem Orders Cancelling Filter überein.
- direction
- Orderseite. Wenn der Wert , die Richtung nicht verwendet.
- board
- Trading Board. Wenn der Wert gleich , dann stimmt das Board nicht mit dem Orders Cancelling Filter überein.
- security
- Instrument. Wenn der Wert gleich ist, dann stimmt das Instrument nicht mit dem Orders Cancellation Filter überein.
- securityType
- Art des Finanzinstruments: Wenn der Wert , wird der Typ nicht verwendet.
- transactionId
- Transaktions-ID der Auftragsstornierung.
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)
Bestellungen durch Filter asynchron abbrechen.
- isStopOrder
- , wenn nur eine Stop-Orders stornieren, - wenn reguläre Bestellungen, - beides.
- portfolio
- Portfolio. Wenn der Wert gleich , dann stimmt das Portfolio nicht mit dem Orders Cancelling Filter überein.
- direction
- Orderseite. Wenn der Wert , die Richtung nicht verwendet.
- board
- Trading Board. Wenn der Wert gleich , dann stimmt das Board nicht mit dem Orders Cancelling Filter überein.
- security
- Instrument. Wenn der Wert gleich ist, dann stimmt das Instrument nicht mit dem Orders Cancellation Filter überein.
- securityType
- Art des Finanzinstruments: Wenn der Wert , wird der Typ nicht verwendet.
- transactionId
- Transaktions-ID der Auftragsstornierung.
- cancellationToken
- CancellationToken
public ValueTask ChangePasswordAsync(SecureString newPassword, CancellationToken cancellationToken)
result = connector.ChangePasswordAsync(newPassword, cancellationToken)
Passwort ändern.
- newPassword
- Neues Passwort.
- cancellationToken
- CancellationToken
public virtual ValueTask ClearCacheAsync(CancellationToken cancellationToken)
result = connector.ClearCacheAsync(cancellationToken)
Cache freigeben.
protected string CreateSecurityId(string secCode, string boardCode)
result = connector.CreateSecurityId(secCode, boardCode)
Id-Finanzinstrument generieren.
- secCode
- SecurityCode.
- boardCode
- BoardCode.
Rückgabe: Id Finanzinstrument.
protected override void DisposeManaged()
connector.DisposeManaged()
Um zugewiesene Ressourcen freizugeben, insbesondere um sich vom Handelssystem über Disconnect zu trennen.
public void EditOrder(Order order, Order changes)
connector.EditOrder(order, changes)
Bearbeiten Sie die Bestellung.
- order
- Bestellung.
- changes
- Ordnungsänderungen.
public ValueTask EditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.EditOrderAsync(order, changes, cancellationToken)
Bearbeiten Sie die Reihenfolge asynchron.
- order
- Befehl zum Bearbeiten.
- changes
- Ordnung, sich mit neuen Werten zu ändern.
- cancellationToken
- CancellationToken
public IEnumerable<Level1Fields> GetLevel1Fields(Security security)
result = connector.GetLevel1Fields(security)
Um eine Reihe von verfügbaren Feldern Level1Fields zu erhalten, für die es Marktdaten für das Instrument gibt.
- security
- Finanzinstrument.
Rückgabe: Mögliche Felder.
public Portfolio GetPortfolio(string name)
result = connector.GetPortfolio(name)
Um das Portfolio nach dem Codenamen zu erhalten.
- name
- Portfolio-Code-Name.
Rückgabe: Wenn es kein Portfolio nach vorgegebenen Kriterien gibt, wird es zurückgegeben.
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)
Um die Position nach Portfolio und Instrument zu erhalten.
- portfolio
- Das Portfolio, auf dem die Position gefunden werden sollte.
- security
- Das Instrument, auf dem die Position gefunden werden soll.
- strategyId
- Strategie-ID.
- side
- Seite.
- clientCode
- Der Client-Code.
- depoName
- Standardmäßig wird ein leerer String übergeben, d. h. die Gesamtposition aller Verwahrstellen.
- limitType
- Limit type for Т+ market.
Rückgabe: Position.
public Security GetSecurity(SecurityId securityId)
result = connector.GetSecurity(securityId)
Erhalten Sie das Finanzinstrument nach Identifikator.
- securityId
- Kennung des Finanzinstruments.
Rückgabe: Finanzinstrument.
private ValueTask<Security> GetSecurityAsync(SecurityId id, Func<Security, bool> changeSecurity, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(id, changeSecurity, cancellationToken)
Um das Instrument durch den Code zu bekommen.
- id
- Kennung des Finanzinstruments.
- changeSecurity
- Der Handler, der das Instrument wechselt. Er gibt zurück, wenn das Instrument gewechselt wurde und SecurityReceived aufgerufen werden soll.
- cancellationToken
- CancellationToken
Rückgabe: Finanzinstrument.
public ValueTask<Security> GetSecurityAsync(SecurityId securityId, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(securityId, cancellationToken)
Erhalten Sie das Finanzinstrument nach Identifikator.
- securityId
- Kennung des Finanzinstruments.
- cancellationToken
- CancellationToken
Rückgabe: Finanzinstrument.
public SecurityId GetSecurityId(Security security)
result = connector.GetSecurityId(security)
Holen Sie sich SecurityId.
- security
- Finanzinstrument.
Rückgabe: Kennung des Finanzinstruments.
public object GetSecurityValue(Security security, Level1Fields field)
result = connector.GetSecurityValue(security, field)
Um den Wert der Marktdaten für das Instrument zu erhalten.
- security
- Finanzinstrument.
- field
- Feld Marktdaten.
Rückgabe: Wenn keine Daten vorliegen, wird der Feldwert zurückgegeben.
private ValueTask InitNewOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.InitNewOrderAsync(order, cancellationToken)
Initialisieren Sie die Registrierungsreihenfolge (Transaktions-ID usw.).
- order
- Neue Ordnung.
- cancellationToken
- CancellationToken
public bool? IsOrderEditable(Order order)
result = connector.IsOrderEditable(order)
Bestimmt, dass die angegebene Reihenfolge von Order bearbeitet werden kann.
- order
- Bestellung.
Rückgabe: wenn die Bestellung editierbar ist, die Bestellung nicht geändert werden kann, bedeutet keine Informationen.
public bool? IsOrderReplaceable(Order order)
result = connector.IsOrderReplaceable(order)
Bestimmt, dass die angegebene Reihenfolge durch die Bestellung ersetzt werden kann.
- order
- Bestellung.
Rückgabe: wenn die Bestellung austauschbar ist, Bestellung kann nicht ersetzt werden, bedeutet keine Informationen.
public override void Load(SettingsStorage storage)
connector.Load(storage)
Lasteinstellungen.
- storage
- Einstellungen Lagerung.
public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
result = connector.LookupByIdAsync(id, cancellationToken)
Um das Instrument durch den Identifikator zu erhalten.
- id
- Kennung des Finanzinstruments.
- cancellationToken
- CancellationToken
Rückgabe: Wenn es kein Instrument nach vorgegebenen Kriterien gibt, wird es zurückgegeben.
public Portfolio LookupByPortfolioName(string name)
result = connector.LookupByPortfolioName(name)
Um das Portfolio nach dem Codenamen zu erhalten.
- name
- Portfolio-Code-Name.
Rückgabe: Wenn es kein Portfolio nach vorgegebenen Kriterien gibt, wird es zurückgegeben.
protected ValueTask OnCancelOrderAsync(Order order, long transactionId, CancellationToken cancellationToken)
result = connector.OnCancelOrderAsync(order, transactionId, cancellationToken)
Stornieren Sie die Bestellung.
- order
- Anweisung zur Stornierung.
- transactionId
- Transaktions-ID der Auftragsstornierung.
- 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)
Bestellungen per Filter stornieren.
- transactionId
- Transaktions-ID der Auftragsstornierung.
- cancellationToken
- Löschungszeichen.
- isStopOrder
- , wenn nur eine Stop-Orders stornieren, - wenn reguläre Bestellungen, - beides.
- portfolio
- Portfolio. Wenn der Wert gleich , dann stimmt das Portfolio nicht mit dem Orders Cancelling Filter überein.
- direction
- Orderseite. Wenn der Wert , die Richtung nicht verwendet.
- board
- Trading Board. Wenn der Wert gleich , dann stimmt das Board nicht mit dem Orders Cancelling Filter überein.
- security
- Instrument. Wenn der Wert gleich ist, dann stimmt das Instrument nicht mit dem Orders Cancellation Filter überein.
- securityType
- Art des Finanzinstruments: Wenn der Wert , wird der Typ nicht verwendet.
protected virtual ValueTask OnConnectAsync(CancellationToken cancellationToken)
result = connector.OnConnectAsync(cancellationToken)
Verbinden Sie sich mit dem Handelssystem.
protected virtual ValueTask OnDisconnectAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectAsync(cancellationToken)
Trennen Sie sich vom Handelssystem.
protected ValueTask OnEditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.OnEditOrderAsync(order, changes, cancellationToken)
Bearbeiten Sie die Bestellung.
- order
- Bestellung.
- changes
- Ordnungsänderungen.
- cancellationToken
- CancellationToken
protected virtual ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)
result = connector.OnProcessMessage(message, cancellationToken)
Prozessmeldung.
- message
- Nachricht.
- cancellationToken
- CancellationToken
protected ValueTask OnRegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.OnRegisterOrderAsync(order, cancellationToken)
Registrieren Sie neue Bestellung.
- order
- Angaben zur Registrierung.
- cancellationToken
- CancellationToken
protected ValueTask OnReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.OnReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Registrieren Sie die Bestellung erneut.
- oldOrder
- Löschung des Auftrags.
- newOrder
- Neue Registrierungsanordnung.
- cancellationToken
- CancellationToken
private void RaiseConnected()
connector.RaiseConnected()
Um das Ereignis Connected aufzurufen.
private void RaiseConnectedEx(IMessageAdapter adapter)
connector.RaiseConnectedEx(adapter)
Um das Ereignis ConnectedEx aufzurufen.
- adapter
- Adapter, initiierte Veranstaltung.
private void RaiseConnectionError(Exception exception)
connector.RaiseConnectionError(exception)
Um das Ereignis ConnectionError aufzurufen.
- exception
- Fehlerverbindung.
private void RaiseConnectionErrorEx(IMessageAdapter adapter, Exception exception)
connector.RaiseConnectionErrorEx(adapter, exception)
Um das Ereignis ConnectionErrorEx aufzurufen.
- adapter
- Adapter, initiierte Veranstaltung.
- exception
- Fehlerverbindung.
private void RaiseCurrentTimeChanged(TimeSpan diff)
connector.RaiseCurrentTimeChanged(diff)
Um das Ereignis CurrentTimeChanged aufzurufen.
- diff
- Die Zeitdifferenz seit dem letzten Aufruf des Ereignisses. Das erste Mal, wenn das Ereignis den Wert Null überschreitet.
private void RaiseDisconnected()
connector.RaiseDisconnected()
Um das Ereignis Disconnected aufzurufen.
private void RaiseDisconnectedEx(IMessageAdapter adapter)
connector.RaiseDisconnectedEx(adapter)
Um das Ereignis DisconnectedEx aufzurufen.
- adapter
- Adapter, initiierte Veranstaltung.
protected void RaiseError(Exception exception)
connector.RaiseError(exception)
Um das Ereignis Fehler aufzurufen.
- exception
- Fehler bei der Datenverarbeitung.
private void RaiseLookupPortfoliosResult(PortfolioLookupMessage message, Exception error, Portfolio[] newPortfolios)
connector.RaiseLookupPortfoliosResult(message, error, newPortfolios)
Um das Ereignis LookupPortfoliosResult aufzurufen.
- message
- Nachricht.
- error
- Ein Fehler der Nachschlagoperation. Der Wert ist, wenn die Operation erfolgreich abgeschlossen wird.
- newPortfolios
- Portfolios gefunden.
private void RaiseLookupSecuritiesResult(SecurityLookupMessage message, Exception error, Security[] newSecurities)
connector.RaiseLookupSecuritiesResult(message, error, newSecurities)
Um das Ereignis LookupSecuritiesResult aufzurufen.
- message
- Nachricht.
- error
- Ein Fehler der Nachschlagoperation. Der Wert ist, wenn die Operation erfolgreich abgeschlossen wird.
- newSecurities
- Gefundene Instrumente.
protected virtual void RaiseSubscriptionFailed(Subscription subscription, Exception error, bool isSubscribe)
connector.RaiseSubscriptionFailed(subscription, error, isSubscribe)
public void RegisterOrder(Order order)
connector.RegisterOrder(order)
Registrieren Sie neue Bestellung.
- order
- Angaben zur Registrierung.
public ValueTask RegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.RegisterOrderAsync(order, cancellationToken)
Registrieren Sie neue Bestellung asynchron.
- order
- Angaben zur Registrierung.
- cancellationToken
- CancellationToken
public void ReRegisterOrder(Order oldOrder, Order newOrder)
connector.ReRegisterOrder(oldOrder, newOrder)
Registrieren Sie die Bestellung erneut.
- oldOrder
- Löschung des Auftrags.
- newOrder
- Neue Registrierungsanordnung.
public ValueTask ReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.ReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
Registrieren Sie die Bestellung asynchron.
- oldOrder
- Löschung des Auftrags.
- newOrder
- Neue Registrierungsanordnung.
- cancellationToken
- CancellationToken
public override void Save(SettingsStorage storage)
connector.Save(storage)
Einstellungen speichern.
- storage
- Einstellungen Lagerung.
public void SendInMessage(Message message)
connector.SendInMessage(message)
Senden Sie eine Nachricht vom Servermodul an verbundene Clients.
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendInMessageAsync(message, cancellationToken)
Verarbeitet eine generische Nachricht asynchron.
- message
- Die Botschaft zum Prozess.
- cancellationToken
- CancellationToken
public void SendOutError(Exception error)
connector.SendOutError(error)
Senden Sie eine Fehlermeldung.
- error
- Angaben zu Fehlern.
public ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = connector.SendOutErrorAsync(error, cancellationToken)
Senden Sie eine Fehlermeldung.
- error
- Angaben zu Fehlern.
- cancellationToken
- CancellationToken
public void SendOutMessage(Message message)
connector.SendOutMessage(message)
Senden Sie ausgehende Nachricht.
- message
- Nachricht.
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendOutMessageAsync(message, cancellationToken)
Senden Sie ausgehende Nachrichten (Zustandsänderung, Reihenfolge usw.).
- message
- Nachricht.
- cancellationToken
- CancellationToken
public void Subscribe(Subscription subscription)
connector.Subscribe(subscription)
Unterzeichnen.
- subscription
- Zeichnung.
public void UnSubscribe(Subscription subscription)
connector.UnSubscribe(subscription)
Unsubscribe.
- subscription
- Zeichnung.
Ereignisse
public event Action<Subscription, ExchangeBoard> BoardReceived
connector.BoardReceived += handler
ExchangeBoard erhalten.
public event Action<Subscription, ICandleMessage> CandleReceived
connector.CandleReceived += handler
ICandleMessage erhalten.
public event Action<long, Exception> ChangePasswordResult
connector.ChangePasswordResult += handler
Ergebnis Passwort ändern.
public event Action<IMessageAdapter> ConnectedEx
connector.ConnectedEx += handler
Verbunden.
public event Action<Exception> ConnectionError
connector.ConnectionError += handler
Verbindungsfehler (z. B. wurde die Verbindung vom Server abgebrochen).
public event Action<IMessageAdapter, Exception> ConnectionErrorEx
connector.ConnectionErrorEx += handler
Verbindungsfehler (z. B. wurde die Verbindung vom Server abgebrochen).
public event Action<IMessageAdapter> ConnectionLost
connector.ConnectionLost += handler
Verbindung verloren.
public event Action<IMessageAdapter> ConnectionRestored
connector.ConnectionRestored += handler
Verbindung wiederhergestellt.
public event Action<TimeSpan> CurrentTimeChanged
connector.CurrentTimeChanged += handler
Die Serverzeit hat sich geändert CurrentTime. Es hat die Zeitdifferenz seit dem letzten Aufruf des Ereignisses überschritten. Das erste Mal passiert das Ereignis den Wert Null.
public event Action<Subscription, DataType> DataTypeReceived
connector.DataTypeReceived += handler
DataType erhalten.
public event Action<IMessageAdapter> DisconnectedEx
connector.DisconnectedEx += handler
Abgeschlossen.
public event Action<Subscription, Level1ChangeMessage> Level1Received
connector.Level1Received += handler
Level1ChangeMessage erhalten.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult
connector.LookupPortfoliosResult += handler
Lookup Ergebnis PortfolioLookupMessage erhalten.
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult2
connector.LookupPortfoliosResult2 += handler
Lookup Ergebnis PortfolioLookupMessage erhalten.
public event Action<SecurityLookupMessage, IEnumerable<Security>, Exception> LookupSecuritiesResult
connector.LookupSecuritiesResult += handler
Lookup Ergebnis SecurityLookupMessage erhalten.
public event Action<SecurityLookupMessage, IEnumerable<Security>, IEnumerable<Security>, Exception> LookupSecuritiesResult2
connector.LookupSecuritiesResult2 += handler
Lookup Ergebnis SecurityLookupMessage erhalten.
public event Action<long> MassOrderCanceled
connector.MassOrderCanceled += handler
Massenauftrag Stornierung Ereignis.
public event Action<long, DateTime> MassOrderCanceled2
connector.MassOrderCanceled2 += handler
Massenauftrag Stornierung Ereignis.
public event Action<long, Exception> MassOrderCancelFailed
connector.MassOrderCancelFailed += handler
Massenauftrag Stornierung Fehler Ereignis.
public event Action<long, Exception, DateTime> MassOrderCancelFailed2
connector.MassOrderCancelFailed2 += handler
Massenauftrag Stornierung Fehler Ereignis.
public event Action<MyTrade> NewMyTrade
connector.NewMyTrade += handler
Eigenhandel erhalten.
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
connector.NewOutMessageAsync += handler
Neues Nachrichtenereignis.
public event Action<Portfolio> NewPortfolio
connector.NewPortfolio += handler
Neues Portfolio erhalten.
public event Action<Position> NewPosition
connector.NewPosition += handler
Neue Position erhalten.
public event Action<Subscription, News> NewsReceived
connector.NewsReceived += handler
Nachrichten erhalten.
public event Action<Subscription, IOrderBookMessage> OrderBookReceived
connector.OrderBookReceived += handler
IOrderBookMessage erhalten.
public event Action<OrderFail> OrderCancelFailed
connector.OrderCancelFailed += handler
Order Stornierung Fehlerereignis.
public event Action<Subscription, OrderFail> OrderCancelFailReceived
connector.OrderCancelFailReceived += handler
OrderFail Stornierungsereignis.
public event Action<Order> OrderChanged
connector.OrderChanged += handler
Bestellung geändert (abgesagt, abgeglichen).
public event Action<long, Order> OrderEdited
connector.OrderEdited += handler
Order) Erfolg Ergebnis Ereignis.
public event Action<long, OrderFail> OrderEditFailed
connector.OrderEditFailed += handler
Order) Fehlerergebnis Ereignis.
public event Action<Subscription, OrderFail> OrderEditFailReceived
connector.OrderEditFailReceived += handler
OrderFail Editionsveranstaltung.
public event Action<Subscription, IOrderLogMessage> OrderLogReceived
connector.OrderLogReceived += handler
IOrderLogMessage erhalten.
public event Action<Subscription, Order> OrderReceived
connector.OrderReceived += handler
Bestellung eingegangen.
public event Action<OrderFail> OrderRegisterFailed
connector.OrderRegisterFailed += handler
Fehler bei der Auftragsregistrierung.
public event Action<Subscription, OrderFail> OrderRegisterFailReceived
connector.OrderRegisterFailReceived += handler
OrderFail Registrierungsereignis.
public event Action<Subscription, MyTrade> OwnTradeReceived
connector.OwnTradeReceived += handler
MyTrade erhalten.
public event Action<Portfolio> PortfolioChanged
connector.PortfolioChanged += handler
Portfolio geändert.
public event Action<Subscription, Portfolio> PortfolioReceived
connector.PortfolioReceived += handler
Portfolio erhalten.
public event Action<Position> PositionChanged
connector.PositionChanged += handler
Position geändert.
public event Action<Subscription, Position> PositionReceived
connector.PositionReceived += handler
Position erhalten.
public event Action<Subscription, Security> SecurityReceived
connector.SecurityReceived += handler
erhaltenes Finanzinstrument.
public event Action<Subscription, Exception, bool> SubscriptionFailed
connector.SubscriptionFailed += handler
Das Abonnement ist fehlgeschlagen.
public event Action<Subscription> SubscriptionOnline
connector.SubscriptionOnline += handler
Das Abonnement ist online.
public event Action<Subscription, object> SubscriptionReceived
connector.SubscriptionReceived += handler
Wert erhalten.
public event Action<Subscription> SubscriptionStarted
connector.SubscriptionStarted += handler
Das Abonnement wird gestartet.
public event Action<Subscription, Exception> SubscriptionStopped
connector.SubscriptionStopped += handler
Das Abonnement wird gestoppt.
public event Action<Subscription, ITickTradeMessage> TickTradeReceived
connector.TickTradeReceived += handler
ITickTradeMessage erhalten.
public event Action<Security, IEnumerable<KeyValuePair<Level1Fields, object>>, DateTime, DateTime> ValuesChanged
connector.ValuesChanged += handler
Finanzinstrument geändert.