BasketMessageAdapter
異なる取引システムに接続された複数のアダプターを同時に動作させることができるアダプター・アグレゲータ。
継承元: BaseLogReceiver
実装: IMessageAdapterWrapper, IMessageAdapter, IMessageTransport, IPersistable, ILogReceiver, ILogSource, IDisposable, ICloneable<IMessageAdapter>, ICloneable
コンストラクター
public BasketMessageAdapter(IdGenerator transactionIdGenerator, CandleBuilderProvider candleBuilderProvider, ISecurityMessageAdapterProvider securityAdapterProvider, IPortfolioMessageAdapterProvider portfolioAdapterProvider, IStorageBuffer buffer)
basketMessageAdapter = BasketMessageAdapter(transactionIdGenerator, candleBuilderProvider, securityAdapterProvider, portfolioAdapterProvider, buffer)
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)
注射可能な依存関係を持つBasketMessageAdapterの新規インスタンスを初期化します。
プロパティ
public ICommissionManager CommissionManager { get; set; }
value = basketMessageAdapter.CommissionManager
basketMessageAdapter.CommissionManager = value
マネージャーを計算する手数料。
public bool ConnectDisconnectEventOnFirstAdapter { get; set; }
value = basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter
basketMessageAdapter.ConnectDisconnectEventOnFirstAdapter = value
初回アダプターがInnerAdaptersに繋がるConnectMessage@イベントを呼び出します。
public IExtendedInfoStorage ExtendedInfoStorage { get; set; }
value = basketMessageAdapter.ExtendedInfoStorage
basketMessageAdapter.ExtendedInfoStorage = value
拡張された情報ストレージ。
public IFillGapsBehaviour FillGapsBehaviour { get; set; }
value = basketMessageAdapter.FillGapsBehaviour
basketMessageAdapter.FillGapsBehaviour = value
担当: 佐藤 宏
public bool GenerateOrderBookFromLevel1 { get; set; }
value = basketMessageAdapter.GenerateOrderBookFromLevel1
basketMessageAdapter.GenerateOrderBookFromLevel1 = value
Level1のデータから注文書を生成します。
public bool IgnoreExtraAdapters { get; set; }
value = basketMessageAdapter.IgnoreExtraAdapters
basketMessageAdapter.IgnoreExtraAdapters = value
追加のアダプターを追加しないでください。
public IInnerAdapterList InnerAdapters { get; }
value = basketMessageAdapter.InnerAdapters
集計者が動作するアダプター。
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
basketMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value
再接続でサブスクリプションを復元します。
public bool IsSecurityNewsOnly { get; }
value = basketMessageAdapter.IsSecurityNewsOnly
アダプターは、特定金融商品に関連するニュースを提供します。
public bool IsSupportTransactionLog { get; set; }
value = basketMessageAdapter.IsSupportTransactionLog
basketMessageAdapter.IsSupportTransactionLog = value
Use TransactionOrderingMessageAdapter.
public ILatencyManager LatencyManager { get; set; }
value = basketMessageAdapter.LatencyManager
basketMessageAdapter.LatencyManager = value
注文登録遅延計算マネージャ。
public bool Level1Extend { get; set; }
value = basketMessageAdapter.Level1Extend
basketMessageAdapter.Level1Extend = value
Use Level1ExtendBuilderAdapter.
public ISecurityMappingStorageProvider MappingProvider { get; set; }
value = basketMessageAdapter.MappingProvider
basketMessageAdapter.MappingProvider = value
金融機器識別子は、ストレージプロバイダをマッピングします。
public INativeIdStorageProvider NativeIdStorage { get; set; }
value = basketMessageAdapter.NativeIdStorage
basketMessageAdapter.NativeIdStorage = value
金融商品名簿記帳プロバイダ。
public IPnLManager PnLManager { get; set; }
value = basketMessageAdapter.PnLManager
basketMessageAdapter.PnLManager = value
利益損失のマネージャー。
public IPortfolioMessageAdapterProvider PortfolioAdapterProvider { get; }
value = basketMessageAdapter.PortfolioAdapterProvider
ポートフォリオベースのメッセージアダプタのプロバイダ。
public IBasketRoutingManager RoutingManager { get; }
value = basketMessageAdapter.RoutingManager
ルーティングマネージャーを取得します。
public ISecurityMessageAdapterProvider SecurityAdapterProvider { get; }
value = basketMessageAdapter.SecurityAdapterProvider
金融商品ベースのメッセージアダプタのプロバイダ。
public bool SendFinishedCandlesImmediatelly { get; set; }
value = basketMessageAdapter.SendFinishedCandlesImmediatelly
basketMessageAdapter.SendFinishedCandlesImmediatelly = value
代表取締役社長 佐藤 浩
public ISlippageManager SlippageManager { get; set; }
value = basketMessageAdapter.SlippageManager
basketMessageAdapter.SlippageManager = value
スリップページマネージャー。
public IStorageProcessor StorageProcessor { get; }
value = basketMessageAdapter.StorageProcessor
ストレージプロセッサ。
public StorageCoreSettings StorageSettings { get; }
value = basketMessageAdapter.StorageSettings
ストレージ設定。
public bool SupportBuildingFromOrderLog { get; set; }
value = basketMessageAdapter.SupportBuildingFromOrderLog
basketMessageAdapter.SupportBuildingFromOrderLog = value
Use OrderLogMessageAdapter.
public bool SupportCandlesCompression { get; set; }
value = basketMessageAdapter.SupportCandlesCompression
basketMessageAdapter.SupportCandlesCompression = value
Use CandleBuilderMessageAdapter.
public bool SupportLookupTracking { get; set; }
value = basketMessageAdapter.SupportLookupTracking
basketMessageAdapter.SupportLookupTracking = value
Use LookupTrackingMessageAdapter.
public bool SupportOffline { get; set; }
value = basketMessageAdapter.SupportOffline
basketMessageAdapter.SupportOffline = value
Use OfflineMessageAdapter.
public bool SupportOrderBookTruncate { get; set; }
value = basketMessageAdapter.SupportOrderBookTruncate
basketMessageAdapter.SupportOrderBookTruncate = value
Use OrderBookTruncateMessageAdapter.
public bool SupportSecurityAll { get; set; }
value = basketMessageAdapter.SupportSecurityAll
basketMessageAdapter.SupportSecurityAll = value
Use SubscriptionSecurityAllMessageAdapter.
public bool SupportStorage { get; set; }
value = basketMessageAdapter.SupportStorage
basketMessageAdapter.SupportStorage = value
Use StorageMessageAdapter.
public bool SuppressOrderBookIncrements { get; set; }
value = basketMessageAdapter.SuppressOrderBookIncrements
basketMessageAdapter.SuppressOrderBookIncrements = value
この場合、OrderBookIncrementMessageAdapterはパイプラインに追加されません。内部アダプターがIsSupportOrderBookIncrements@に報告しても、パイプラインに追加されません。
public bool SuppressReconnectingErrors { get; set; }
value = basketMessageAdapter.SuppressReconnectingErrors
basketMessageAdapter.SuppressReconnectingErrors = value
エラーを再接続する抑制。
public IdGenerator TransactionIdGenerator { get; set; }
value = basketMessageAdapter.TransactionIdGenerator
basketMessageAdapter.TransactionIdGenerator = value
内部の子サブスクリプションルーティングに使用されるトランザクションIDジェネレータ。 親アダプターのジェネレータと同期して保存する必要があります。
public bool UseInChannel { get; set; }
value = basketMessageAdapter.UseInChannel
basketMessageAdapter.UseInChannel = value
メッセージを入力するためのチャンネルを使用します。
public bool UseOutChannel { get; set; }
value = basketMessageAdapter.UseOutChannel
basketMessageAdapter.UseOutChannel = value
メッセージを発信するためのチャンネルを使用します。
メソッド
public void ApplyHeartbeat(IMessageAdapter adapter, bool on)
basketMessageAdapter.ApplyHeartbeat(adapter, on)
指定されたアダプターのオン/オフハートビートモードを適用します。
public IMessageAdapter Clone()
result = basketMessageAdapter.Clone()
コピーの作成BasketMessageAdapter
protected override void DisposeManaged()
basketMessageAdapter.DisposeManaged()
割り当てられたリソースを解放するには.
protected IEnumerable<IMessageAdapter> GetSortedAdapters()
result = basketMessageAdapter.GetSortedAdapters()
アダプターSortedAdaptersを所定の優先順位でソートします。
public override void Load(SettingsStorage storage)
basketMessageAdapter.Load(storage)
設定をロードします。
- storage
- 設定ストレージ。
protected virtual ValueTask OnInnerAdapterNewOutMessage(IMessageAdapter innerAdapter, Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnInnerAdapterNewOutMessage(innerAdapter, message, cancellationToken)
組み込みアダプターイベントハンドラ。
protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
送信する
protected virtual ValueTask OnSendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.OnSendOutMessageAsync(message, cancellationToken)
発信メッセージ送信とNewOutMessageAsyncイベントの立ち上げ
public override void Save(SettingsStorage storage)
basketMessageAdapter.Save(storage)
設定を保存します。
- storage
- 設定ストレージ。
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = basketMessageAdapter.SendOutMessageAsync(message, cancellationToken)
発信メッセージ(状態変更、注文など)を送信します。
- message
- ご挨拶
- cancellationToken
- 担当: 佐藤 宏
public bool TryGetAdapter(string porfolioName, IMessageAdapter adapter)
result = basketMessageAdapter.TryGetAdapter(porfolioName, adapter)
ポートフォリオ名でアダプターを見つけよう。
イベント
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
basketMessageAdapter.NewOutMessageAsync += handler
新規メッセージイベント