Connector
取引システムへの接続を作成するクラス。
継承元: BaseLogReceiver
実装: IConnector, IMessageTransport, IAsyncPersistable, ILogReceiver, ILogSource, IDisposable, IMarketDataProvider, ITransactionProvider, ISecurityProvider, ISecurityMessageProvider, ISubscriptionProvider, ITimeProvider, IPortfolioProvider, IPositionProvider, IAsyncDisposable
コンストラクター
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)
Connector の新規インスタンスを初期化します。
- securityStorage
- 金融商品メタ情報ストレージ。
- positionStorage
- 位置の貯蔵。
- exchangeInfoProvider
- 取引所および取引銀行のプロバイダ。
- storageRegistry
- 市場データの保存。
- snapshotRegistry
- スナップショットストレージレジストリ。
- buffer
- ストレージバッファ。
- initAdapter
- バスケットのアダプターを初期化して下さい。
- initChannels
- チャネルを初期化します。
プロパティ
public BasketMessageAdapter Adapter { get; protected set; }
value = connector.Adapter
connector.Adapter = value
メッセージアダプタ。
public IBasketSecurityProcessorProvider BasketSecurityProcessorProvider { get; set; }
value = connector.BasketSecurityProcessorProvider
connector.BasketSecurityProcessorProvider = value
バスケット金融商品取引業者プロバイダ。
public Subscription BoardLookup { get; }
value = connector.BoardLookup
ExchangeBoard 参照でグローバルサブスクリプションを入手してください。 できます。
public bool CanConnect { get; }
value = connector.CanConnect
接続の確立準備は完了です。connectorを決定します。
public bool CheckSteps { get; set; }
value = connector.CheckSteps
connector.CheckSteps = value
価格とボリュームは、ステップに乗っ掛ける.
public ICommissionManager CommissionManager { get; set; }
value = connector.CommissionManager
connector.CommissionManager = value
マネージャーを計算する手数料。
public ConnectionStates ConnectionState { get; private set; }
value = connector.ConnectionState
connector.ConnectionState = value
接続状態。
public Subscription DataTypeLookup { get; }
value = connector.DataTypeLookup
DataTypeInfoMessage 参照でグローバルサブスクリプションを入手してください。 できます。
public int ErrorCount { get; private set; }
value = connector.ErrorCount
connector.ErrorCount = value
エラーイベントを通過したエラーの数。
public IEnumerable<ExchangeBoard> ExchangeBoards { get; }
value = connector.ExchangeBoards
株式ボードの一覧です。
public IExchangeInfoProvider ExchangeInfoProvider { get; }
value = connector.ExchangeInfoProvider
取引所および取引銀行のプロバイダ。
public IMessageChannel InMessageChannel { get; protected set; }
value = connector.InMessageChannel
connector.InMessageChannel = value
メッセージを入力するチャネル。
public IMessageAdapterWrapper InnerAdapter { get; set; }
value = connector.InnerAdapter
connector.InnerAdapter = value
内部メッセージのアダプター。
public bool IsAutoUnSubscribeOnDisconnect { get; set; }
value = connector.IsAutoUnSubscribeOnDisconnect
connector.IsAutoUnSubscribeOnDisconnect = value
接続解除コマンドを解除する
public bool IsRestoreSubscriptionOnNormalReconnect { get; set; }
value = connector.IsRestoreSubscriptionOnNormalReconnect
connector.IsRestoreSubscriptionOnNormalReconnect = value
再接続でサブスクリプションを復元します。
public ILatencyManager LatencyManager { get; set; }
value = connector.LatencyManager
connector.LatencyManager = value
注文登録遅延計算マネージャ。
public ISet<MessageTypes> LookupMessagesOnConnect { get; }
value = connector.LookupMessagesOnConnect
public IMessageAdapter MarketDataAdapter { get; private set; }
value = connector.MarketDataAdapter
connector.MarketDataAdapter = value
市場データ アダプター。
public virtual TimeSpan MarketTimeChangedInterval { get; set; }
value = connector.MarketTimeChangedInterval
connector.MarketTimeChangedInterval = value
TimeMessage@ メッセージを生成します。 デフォルトは10ミリ秒です。
public Subscription OrderLookup { get; }
value = connector.OrderLookup
注文検索でグローバルサブスクリプションを入手してください。 できます。
public int OrdersKeepCount { get; set; }
value = connector.OrdersKeepCount
connector.OrdersKeepCount = value
保存の注文数。デフォルトは1000です。値がMaxValueにセットされている場合、注文は削除されません。値が0に設定されている場合、注文は保存されません。
public IMessageChannel OutMessageChannel { get; protected set; }
value = connector.OutMessageChannel
connector.OutMessageChannel = value
メッセージチャンネルを外します。
public bool OverrideSecurityData { get; set; }
value = connector.OverrideSecurityData
connector.OverrideSecurityData = value
新規値で前回の金融商品データをオーバーライド。
public IPnLManager PnLManager { get; set; }
value = connector.PnLManager
connector.PnLManager = value
利益損失のマネージャー。
public Subscription PortfolioLookup { get; }
value = connector.PortfolioLookup
ポートフォリオの検索でグローバルサブスクリプションを入手できます。
public virtual IEnumerable<Portfolio> Portfolios { get; }
value = connector.Portfolios
ポートフォリオのリスト。
public IPositionStorage PositionStorage { get; }
value = connector.PositionStorage
位置の貯蔵。
public virtual IRiskManager RiskManager { get; set; }
value = connector.RiskManager
connector.RiskManager = value
リスク管理責任者
public SecurityIdGenerator SecurityIdGenerator { get; set; }
value = connector.SecurityIdGenerator
connector.SecurityIdGenerator = value
機器識別子ジェネレータ Id.
public Subscription SecurityLookup { get; }
value = connector.SecurityLookup
金融商品検索でグローバルサブスクリプションを入手できます。
public ISecurityStorage SecurityStorage { get; }
value = connector.SecurityStorage
金融商品メタ情報ストレージ。
public ISlippageManager SlippageManager { get; set; }
value = connector.SlippageManager
connector.SlippageManager = value
スリップページマネージャー。
public ISnapshotRegistry SnapshotRegistry { get; private set; }
value = connector.SnapshotRegistry
connector.SnapshotRegistry = value
スナップショットストレージレジストリ。
public StorageMetaInfoMessageAdapter StorageAdapter { get; private set; }
value = connector.StorageAdapter
connector.StorageAdapter = value
ストレージアダプタ。
public IStorageRegistry StorageRegistry { get; }
value = connector.StorageRegistry
市場データの保存。
public IEnumerable<Subscription> Subscriptions { get; }
value = connector.Subscriptions
サブスクリプションのリスト。
public ISet<Subscription> SubscriptionsOnConnect { get; }
value = connector.SubscriptionsOnConnect
サブスクリプションをコネクトに送信する。
public bool SupportAssociatedSecurity { get; set; }
value = connector.SupportAssociatedSecurity
connector.SupportAssociatedSecurity = value
Use AssociatedSecurityAdapter.
public bool SupportBasketSecurities { get; set; }
value = connector.SupportBasketSecurities
connector.SupportBasketSecurities = value
Use BasketSecurityMessageAdapter.
public bool SupportFilteredMarketDepth { get; set; }
value = connector.SupportFilteredMarketDepth
connector.SupportFilteredMarketDepth = value
Use FilteredMarketDepthAdapter.
public bool SupportLevel1DepthBuilder { get; set; }
value = connector.SupportLevel1DepthBuilder
connector.SupportLevel1DepthBuilder = value
Use Level1DepthBuilderAdapter.
public virtual bool SupportSnapshots { get; set; }
value = connector.SupportSnapshots
connector.SupportSnapshots = value
Use SnapshotHolderMessageAdapter.
public bool TimeChange { get; set; }
value = connector.TimeChange
connector.TimeChange = value
代表取締役 佐藤 浩一 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様 様
public IMessageAdapter TransactionAdapter { get; private set; }
value = connector.TransactionAdapter
connector.TransactionAdapter = value
トランザクションアダプター。
public IdGenerator TransactionIdGenerator { get; set; }
value = connector.TransactionIdGenerator
connector.TransactionIdGenerator = value
内部の子サブスクリプションルーティングに使用されるトランザクションIDジェネレータ。 親アダプターのジェネレータと同期して保存する必要があります。
public virtual bool UnsubscribeOnDisconnect { get; }
value = connector.UnsubscribeOnDisconnect
接続解除を解除する
public bool UpdatePortfolioByChange { get; set; }
value = connector.UpdatePortfolioByChange
connector.UpdatePortfolioByChange = value
PositionChangeMessageメッセージが表示されるときに、ポートフォリオフィールドを更新します。デフォルトでは有効です。
public bool UpdateSecurityByDefinition { get; set; }
value = connector.UpdateSecurityByDefinition
connector.UpdateSecurityByDefinition = value
SecurityMessageメッセージが表示されるときに金融商品フィールドを更新するには、デフォルトで有効です。
public bool UpdateSecurityByLevel1 { get; set; }
value = connector.UpdateSecurityByLevel1
connector.UpdateSecurityByLevel1 = value
Level1ChangeMessageメッセージが表示されるときに金融商品フィールドを更新するには、デフォルトで有効です。
public bool UpdateSecurityLastQuotes { get; set; }
value = connector.UpdateSecurityLastQuotes
connector.UpdateSecurityLastQuotes = value
LastTick、BestBid、BestAskを注文書および/または取引の更新ごとに更新するには。デフォルトで有効です。
メソッド
public void CancelOrder(Order order)
connector.CancelOrder(order)
注文をキャンセルします。
- order
- キャンセルされるべき注文。
public ValueTask CancelOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.CancelOrderAsync(order, cancellationToken)
注文を非同期的にキャンセルします。
- order
- キャンセルの注文。
- 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)
フィルターで注文をキャンセルします。
- isStopOrder
- , ストップオーダーのみをキャンセルした場合, - 正規注文の場合, - 両方.
- portfolio
- ポートフォリオ。 値が等しい場合は、ポートフォリオは注文キャンセルフィルタに一致しません。
- direction
- 注文側。値が値の場合、方向は使用しません。
- board
- 取引ボード。 値が等しい場合は、ボードは注文キャンセルフィルタに一致しません。
- security
- 器械。値が等しい場合、器械は順序のキャンセル フィルターに一致しません。
- securityType
- 金融商品タイプ。値が の場合、型は使用しません。
- transactionId
- 注文キャンセルトランザクションID。
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)
フィルター非同期で注文をキャンセルします。
- isStopOrder
- , ストップオーダーのみをキャンセルした場合, - 正規注文の場合, - 両方.
- portfolio
- ポートフォリオ。 値が等しい場合は、ポートフォリオは注文キャンセルフィルタに一致しません。
- direction
- 注文側。値が値の場合、方向は使用しません。
- board
- 取引ボード。 値が等しい場合は、ボードは注文キャンセルフィルタに一致しません。
- security
- 器械。値が等しい場合、器械は順序のキャンセル フィルターに一致しません。
- securityType
- 金融商品タイプ。値が の場合、型は使用しません。
- transactionId
- 注文キャンセルトランザクションID。
- cancellationToken
- 担当: 佐藤 宏
public ValueTask ChangePasswordAsync(SecureString newPassword, CancellationToken cancellationToken)
result = connector.ChangePasswordAsync(newPassword, cancellationToken)
パスワードを変更します。
- newPassword
- パスワードが新しくなりました。
- cancellationToken
- 担当: 佐藤 宏
public virtual ValueTask ClearCacheAsync(CancellationToken cancellationToken)
result = connector.ClearCacheAsync(cancellationToken)
キャッシュをクリアする。
protected string CreateSecurityId(string secCode, string boardCode)
result = connector.CreateSecurityId(secCode, boardCode)
Id 金融商品取引
- secCode
- 代表取締役社長 佐藤 浩
- boardCode
- 代表取締役社長 佐藤 浩
戻り値: 金融商品取引
public ValueTask DisposeAsync()
result = connector.DisposeAsync()
Performs tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.
protected sealed override void DisposeManaged()
connector.DisposeManaged()
割り当てられたリソースを解放するため。特に、Disconnect を介して取引システムから切断する。
protected virtual ValueTask DisposeManagedAsync()
result = connector.DisposeManagedAsync()
To release allocated resources. In particular, to disconnect from the trading system. It is what both Dispose and DisposeAsync run.
戻り値: ValueTask
public void EditOrder(Order order, Order changes)
connector.EditOrder(order, changes)
注文を編集します。
- order
- 注文。
- changes
- 注文変更。
public ValueTask EditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.EditOrderAsync(order, changes, cancellationToken)
順序を非同期的に編集します。
- order
- 編集する注文。
- changes
- 新たな価値観で変化するオーダー
- cancellationToken
- 担当: 佐藤 宏
public IEnumerable<Level1Fields> GetLevel1Fields(Security security)
result = connector.GetLevel1Fields(security)
利用可能なフィールドのセットを取得するには Level1Fields, そのため、機器の市場データがあります.
- security
- 金融商品取引
戻り値: フィールドを可能とする。
public Portfolio GetPortfolio(string name)
result = connector.GetPortfolio(name)
コード名でポートフォリオを取得する
- name
- ポートフォリオコード名。
戻り値: 取得ポートフォリオ。 与えられた基準でポートフォリオがない場合、返されます。
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)
ポートフォリオや機器でポジションを取得する
- portfolio
- 位置が見つけられるべきポートフォリオ。
- security
- 位置が見つけられるべき器械。
- strategyId
- 戦略ID。
- side
- サイド。
- clientCode
- クライアントコード。
- depoName
- 在庫が物理的に配置されている預金名。デフォルトでは、空の文字列が渡されます。つまり、すべての預金者による総位置を意味します。
- limitType
- Limit type for Т+ market.
戻り値: ポジション。
public Security GetSecurity(SecurityId securityId)
result = connector.GetSecurity(securityId)
識別子で金融商品を入手してください。
- securityId
- 金融商品ID
戻り値: 金融商品取引
private ValueTask<Security> GetSecurityAsync(SecurityId id, Func<Security, bool> changeSecurity, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(id, changeSecurity, cancellationToken)
コードで楽器を取得するには.
- id
- 金融商品ID
- changeSecurity
- 機器の変更のハンドラ。 機器が変更された場合、SecurityReceivedが呼び出されると返します。
- cancellationToken
- 担当: 佐藤 宏
戻り値: 金融商品取引
public ValueTask<Security> GetSecurityAsync(SecurityId securityId, CancellationToken cancellationToken)
result = connector.GetSecurityAsync(securityId, cancellationToken)
識別子で金融商品を入手してください。
- securityId
- 金融商品ID
- cancellationToken
- 担当: 佐藤 宏
戻り値: 金融商品取引
public SecurityId GetSecurityId(Security security)
result = connector.GetSecurityId(security)
担当: 佐藤 浩
- security
- 金融商品取引
戻り値: 金融商品ID
public object GetSecurityValue(Security security, Level1Fields field)
result = connector.GetSecurityValue(security, field)
機器の市場データの価値を取得するため。
- security
- 金融商品取引
- field
- 市場データフィールド。
戻り値: フィールド値。データがない場合、返されます。
private ValueTask InitNewOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.InitNewOrderAsync(order, cancellationToken)
新規登録注文(transaction IDなど)を初期化
- order
- 新規注文
- cancellationToken
- 担当: 佐藤 宏
public bool? IsOrderEditable(Order order)
result = connector.IsOrderEditable(order)
指定した順序をOrderで編集できるかを決定します。
- order
- 注文。
戻り値: 注文が編集可能であれば、注文は変更できません。
public bool? IsOrderReplaceable(Order order)
result = connector.IsOrderReplaceable(order)
指定した順序をOrderで置換できるかどうかを決定します。
- order
- 注文。
戻り値: 注文が置換可能であれば、注文は置換できません。情報は一切意味しません。
public override Task LoadAsync(SettingsStorage storage, CancellationToken cancellationToken)
result = connector.LoadAsync(storage, cancellationToken)
Load settings.
- storage
- Settings storage.
- cancellationToken
- CancellationToken
戻り値: Task
public ValueTask<Security> LookupByIdAsync(SecurityId id, CancellationToken cancellationToken)
result = connector.LookupByIdAsync(id, cancellationToken)
識別子で機器を取得するには.
- id
- 金融商品ID
- cancellationToken
- 担当: 佐藤 宏
戻り値: 取得楽器。条件を与えられた楽器がない場合、返却されます。
public Portfolio LookupByPortfolioName(string name)
result = connector.LookupByPortfolioName(name)
コード名でポートフォリオを取得する
- name
- ポートフォリオコード名。
戻り値: 取得ポートフォリオ。 与えられた基準でポートフォリオがない場合、返されます。
protected ValueTask OnCancelOrderAsync(Order order, long transactionId, CancellationToken cancellationToken)
result = connector.OnCancelOrderAsync(order, transactionId, cancellationToken)
注文をキャンセルします。
- order
- キャンセルの注文。
- transactionId
- 注文キャンセルトランザクションID。
- 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)
フィルターで注文をキャンセルします。
- transactionId
- 注文キャンセルトランザクションID。
- cancellationToken
- キャンセルトークン。
- isStopOrder
- , ストップオーダーのみをキャンセルした場合, - 正規注文の場合, - 両方.
- portfolio
- ポートフォリオ。 値が等しい場合は、ポートフォリオは注文キャンセルフィルタに一致しません。
- direction
- 注文側。値が値の場合、方向は使用しません。
- board
- 取引ボード。 値が等しい場合は、ボードは注文キャンセルフィルタに一致しません。
- security
- 器械。値が等しい場合、器械は順序のキャンセル フィルターに一致しません。
- securityType
- 金融商品タイプ。値が の場合、型は使用しません。
protected virtual ValueTask OnConnectAsync(CancellationToken cancellationToken)
result = connector.OnConnectAsync(cancellationToken)
取引システムに接続する
protected virtual ValueTask OnDisconnectAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectAsync(cancellationToken)
取引システムから切断する。
protected virtual ValueTask OnDisconnectedAsync(CancellationToken cancellationToken)
result = connector.OnDisconnectedAsync(cancellationToken)
Called once the connection is closed, before Disconnected is raised.
- cancellationToken
- CancellationToken
戻り値: ValueTask
protected ValueTask OnEditOrderAsync(Order order, Order changes, CancellationToken cancellationToken)
result = connector.OnEditOrderAsync(order, changes, cancellationToken)
注文を編集します。
- order
- 注文。
- changes
- 注文変更。
- cancellationToken
- 担当: 佐藤 宏
protected virtual ValueTask OnProcessMessage(Message message, CancellationToken cancellationToken)
result = connector.OnProcessMessage(message, cancellationToken)
プロセスメッセージ。
- message
- ご挨拶
- cancellationToken
- 担当: 佐藤 宏
protected ValueTask OnRegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.OnRegisterOrderAsync(order, cancellationToken)
新規注文を登録する
- order
- 参加登録内容
- cancellationToken
- 担当: 佐藤 宏
protected ValueTask OnReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.OnReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
注文を再度登録して下さい。
- oldOrder
- 注文をキャンセルする。
- newOrder
- 新規登録注文
- cancellationToken
- 担当: 佐藤 宏
private void RaiseConnectedEx(IMessageAdapter adapter)
connector.RaiseConnectedEx(adapter)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- adapter
- アダプター、開始されたでき事。
private void RaiseConnectionError(Exception exception)
connector.RaiseConnectionError(exception)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- exception
- エラー接続。
private void RaiseConnectionErrorEx(IMessageAdapter adapter, Exception exception)
connector.RaiseConnectionErrorEx(adapter, exception)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- adapter
- アダプター、開始されたでき事。
- exception
- エラー接続。
private void RaiseCurrentTimeChanged(TimeSpan diff)
connector.RaiseCurrentTimeChanged(diff)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- diff
- イベントの最後の呼び出し以来の時刻の違い。イベントがゼロ値を通過する最初の時間。
private ValueTask RaiseDisconnectedAsync(CancellationToken cancellationToken)
result = connector.RaiseDisconnectedAsync(cancellationToken)
To call the event Disconnected.
private void RaiseDisconnectedEx(IMessageAdapter adapter)
connector.RaiseDisconnectedEx(adapter)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- adapter
- アダプター、開始されたでき事。
protected void RaiseError(Exception exception)
connector.RaiseError(exception)
イベントエラーを呼び出します。
- exception
- データ処理エラー。
private void RaiseLookupPortfoliosResult(PortfolioLookupMessage message, Exception error, Portfolio[] newPortfolios)
connector.RaiseLookupPortfoliosResult(message, error, newPortfolios)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- message
- ご挨拶
- error
- 動作のエラー。 動作が正常に完了すると、値がになります。
- newPortfolios
- ポートフォリオの発見
private void RaiseLookupSecuritiesResult(SecurityLookupMessage message, Exception error, Security[] newSecurities)
connector.RaiseLookupSecuritiesResult(message, error, newSecurities)
開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所: 開催場所:
- message
- ご挨拶
- error
- 動作のエラー。 動作が正常に完了すると、値がになります。
- newSecurities
- 鋳造された器械。
protected virtual void RaiseSubscriptionFailed(Subscription subscription, Exception error, bool isSubscribe)
connector.RaiseSubscriptionFailed(subscription, error, isSubscribe)
public void RegisterOrder(Order order)
connector.RegisterOrder(order)
新規注文を登録する
- order
- 参加登録内容
public ValueTask RegisterOrderAsync(Order order, CancellationToken cancellationToken)
result = connector.RegisterOrderAsync(order, cancellationToken)
新規注文を非同期に登録します。
- order
- 参加登録内容
- cancellationToken
- 担当: 佐藤 宏
private void ReleaseLevel1Ownership(Subscription subscription)
connector.ReleaseLevel1Ownership(subscription)
While an order book or a tick stream runs it is the authority on the Level1 fields it carries and what Level1 says about them is ignored. That ends with the stream: once the last one for the security is gone, Level1 is the only source left and has to report those fields again, or the caller is shown the final value of a stream that ended as if it were the current market.
public void ReRegisterOrder(Order oldOrder, Order newOrder)
connector.ReRegisterOrder(oldOrder, newOrder)
注文を再度登録して下さい。
- oldOrder
- 注文をキャンセルする。
- newOrder
- 新規登録注文
public ValueTask ReRegisterOrderAsync(Order oldOrder, Order newOrder, CancellationToken cancellationToken)
result = connector.ReRegisterOrderAsync(oldOrder, newOrder, cancellationToken)
注文を非同期に再登録します。
- oldOrder
- 注文をキャンセルする。
- newOrder
- 新規登録注文
- cancellationToken
- 担当: 佐藤 宏
public override Task SaveAsync(SettingsStorage storage, CancellationToken cancellationToken)
result = connector.SaveAsync(storage, cancellationToken)
Save settings.
- storage
- Settings storage.
- cancellationToken
- CancellationToken
戻り値: Task
public void SendInMessage(Message message)
connector.SendInMessage(message)
サーバモジュールから接続されたクライアントにメッセージを送る
public ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendInMessageAsync(message, cancellationToken)
一般的なメッセージを非同期に処理します。
- message
- 処理するメッセージ。
- cancellationToken
- 担当: 佐藤 宏
public void SendOutError(Exception error)
connector.SendOutError(error)
エラーメッセージを送信する
- error
- エラーの詳細。
public ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)
result = connector.SendOutErrorAsync(error, cancellationToken)
エラーメッセージを送信する
- error
- エラーの詳細。
- cancellationToken
- 担当: 佐藤 宏
public void SendOutMessage(Message message)
connector.SendOutMessage(message)
送信するメッセージ
- message
- ご挨拶
public ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)
result = connector.SendOutMessageAsync(message, cancellationToken)
発信メッセージ(状態変更、注文など)を送信します。
- message
- ご挨拶
- cancellationToken
- 担当: 佐藤 宏
public void Subscribe(Subscription subscription)
connector.Subscribe(subscription)
購読する
- subscription
- サブスクリプション。
public void UnSubscribe(Subscription subscription)
connector.UnSubscribe(subscription)
退会。
- subscription
- サブスクリプション。
イベント
public event Action<Subscription, ExchangeBoard> BoardReceived
connector.BoardReceived += handler
代表取締役社長 佐藤 浩一
public event Action<Subscription, ICandleMessage> CandleReceived
connector.CandleReceived += handler
代表取締役社長 佐藤 浩一
public event Action<long, Exception> ChangePasswordResult
connector.ChangePasswordResult += handler
パスワード変更
public event Action<Exception> ConnectionError
connector.ConnectionError += handler
接続エラー(例えば、サーバが接続を破棄した)
public event Action<IMessageAdapter, Exception> ConnectionErrorEx
connector.ConnectionErrorEx += handler
接続エラー(例えば、サーバが接続を破棄した)
public event Action<IMessageAdapter> ConnectionLost
connector.ConnectionLost += handler
接続が失われました。
public event Action<IMessageAdapter> ConnectionRestored
connector.ConnectionRestored += handler
接続は元通りに復元されます。
public event Action<TimeSpan> CurrentTimeChanged
connector.CurrentTimeChanged += handler
サーバ時刻は@CurrentTimeに変更しました。イベントの最終呼び出し以来、時間差が経過しました。イベントがゼロ値を通過する最初の時刻です。
public event Action<Subscription, DataType> DataTypeReceived
connector.DataTypeReceived += handler
代表取締役社長 佐藤 浩一
public event Action<IMessageAdapter> DisconnectedEx
connector.DisconnectedEx += handler
切断。
public event Action<Subscription, Level1ChangeMessage> Level1Received
connector.Level1Received += handler
代表取締役社長 佐藤 浩一
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult
connector.LookupPortfoliosResult += handler
結果のPortfolioLookupMessage@を受け取りました。
public event Action<PortfolioLookupMessage, IEnumerable<Portfolio>, IEnumerable<Portfolio>, Exception> LookupPortfoliosResult2
connector.LookupPortfoliosResult2 += handler
結果のPortfolioLookupMessage@を受け取りました。
public event Action<SecurityLookupMessage, IEnumerable<Security>, Exception> LookupSecuritiesResult
connector.LookupSecuritiesResult += handler
結果のSecurityLookupMessage@を受け取りました。
public event Action<SecurityLookupMessage, IEnumerable<Security>, IEnumerable<Security>, Exception> LookupSecuritiesResult2
connector.LookupSecuritiesResult2 += handler
結果のSecurityLookupMessage@を受け取りました。
public event Action<long> MassOrderCanceled
connector.MassOrderCanceled += handler
大量注文キャンセルイベント。
public event Action<long, DateTime> MassOrderCanceled2
connector.MassOrderCanceled2 += handler
大量注文キャンセルイベント。
public event Action<long, Exception> MassOrderCancelFailed
connector.MassOrderCancelFailed += handler
大量注文キャンセルエラーイベント。
public event Action<long, Exception, DateTime> MassOrderCancelFailed2
connector.MassOrderCancelFailed2 += handler
大量注文キャンセルエラーイベント。
public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync
connector.NewOutMessageAsync += handler
新規メッセージイベント
public event Action<Portfolio> NewPortfolio
connector.NewPortfolio += handler
新規ポートフォリオを受領
public event Action<Subscription, News> NewsReceived
connector.NewsReceived += handler
新着情報
public event Action<Subscription, IOrderBookMessage> OrderBookReceived
connector.OrderBookReceived += handler
代表取締役社長 佐藤 浩一
public event Action<OrderFail> OrderCancelFailed
connector.OrderCancelFailed += handler
キャンセルエラーイベントを注文する。
public event Action<Subscription, OrderFail> OrderCancelFailReceived
connector.OrderCancelFailReceived += handler
OrderFail cancellation event.
public event Action<Order> OrderChanged
connector.OrderChanged += handler
注文は変更しました(キャンセル、一致しました)。
public event Action<long, Order> OrderEdited
connector.OrderEdited += handler
注文) 成功の結果イベント。
public event Action<long, OrderFail> OrderEditFailed
connector.OrderEditFailed += handler
注文) エラー結果イベント。
public event Action<Subscription, OrderFail> OrderEditFailReceived
connector.OrderEditFailReceived += handler
OrderFail edition event.
public event Action<Subscription, IOrderLogMessage> OrderLogReceived
connector.OrderLogReceived += handler
代表取締役社長 佐藤 浩一
public event Action<Subscription, Order> OrderReceived
connector.OrderReceived += handler
注文が受け取られた。
public event Action<OrderFail> OrderRegisterFailed
connector.OrderRegisterFailed += handler
注文登録エラーイベント。
public event Action<Subscription, OrderFail> OrderRegisterFailReceived
connector.OrderRegisterFailReceived += handler
OrderFail registration event.
public event Action<Subscription, MyTrade> OwnTradeReceived
connector.OwnTradeReceived += handler
代表取締役社長 佐藤 浩一
public event Action<Portfolio> PortfolioChanged
connector.PortfolioChanged += handler
ポートフォリオ変更
public event Action<Subscription, Portfolio> PortfolioReceived
connector.PortfolioReceived += handler
ポートフォリオが受け取られた。
public event Action<Position> PositionChanged
connector.PositionChanged += handler
ポジション変更
public event Action<Subscription, Position> PositionReceived
connector.PositionReceived += handler
受取される位置。
public event Action<Subscription, Security> SecurityReceived
connector.SecurityReceived += handler
金融商品が受領しました。
public event Action<Subscription, Exception, bool> SubscriptionFailed
connector.SubscriptionFailed += handler
サブスクリプションが失敗しました。
public event Action<Subscription> SubscriptionOnline
connector.SubscriptionOnline += handler
サブスクリプションはオンラインです。
public event Action<Subscription, object> SubscriptionReceived
connector.SubscriptionReceived += handler
受取される価値。
public event Action<Subscription> SubscriptionStarted
connector.SubscriptionStarted += handler
サブスクリプションが始まります。
public event Action<Subscription, Exception> SubscriptionStopped
connector.SubscriptionStopped += handler
サブスクリプションは停止されます。
public event Action<Subscription, ITickTradeMessage> TickTradeReceived
connector.TickTradeReceived += handler
代表取締役社長 佐藤 浩一
public event Action<Security, IEnumerable<KeyValuePair<Level1Fields, object>>, DateTime, DateTime> ValuesChanged
connector.ValuesChanged += handler
金融商品変更