MessageAdapter

MessageAdapter

protected MessageAdapter(IdGenerator transactionIdGenerator)

messageAdapter = MessageAdapter(transactionIdGenerator)

Initialize MessageAdapter.

transactionIdGenerator

トランザクションIDジェネレータ。

AssociatedBoards

public virtual string[] AssociatedBoards { get; }

value = messageAdapter.AssociatedBoards

アダプターは、指定されたボードに関連付けられている機器のみでサブスクリプションを処理できます。

CandlesBuildFrom

public virtual IEnumerable<Level1Fields> CandlesBuildFrom { get; }

value = messageAdapter.CandlesBuildFrom

キャンドルビルのオプションもご用意しています。

Categories

public virtual MessageAdapterCategories Categories { get; }

value = messageAdapter.Categories

メッセージアダプタのカテゴリ。

CheckTimeFrameByRequest

public virtual bool CheckTimeFrameByRequest { get; }

value = messageAdapter.CheckTimeFrameByRequest

リクエストに応じて時間枠を確認できます。

DisconnectTimeout

public virtual TimeSpan DisconnectTimeout { get; }

value = messageAdapter.DisconnectTimeout

優雅な接続を待ちますようにタイムアウトを取得します。

EnqueueSubscriptions

public virtual bool EnqueueSubscriptions { get; set; }

value = messageAdapter.EnqueueSubscriptions
messageAdapter.EnqueueSubscriptions = value

サブスクリプションをエンキューします。

ExtraSetup

public virtual bool ExtraSetup { get; }

value = messageAdapter.ExtraSetup

アダプターは、追加のセットアップが必要です。

FaultDelay

public TimeSpan FaultDelay { get; set; }

value = messageAdapter.FaultDelay
messageAdapter.FaultDelay = value

障害のある反復の間に適用される遅延を得られるか、またはセットします。

FeatureName

public virtual string FeatureName { get; }

value = messageAdapter.FeatureName

フィーチャー名。

FileSystem

public IFileSystem FileSystem { get; set; }

value = messageAdapter.FileSystem
messageAdapter.FileSystem = value

担当: 佐藤 宏

HeartbeatBeforeConnect

public virtual bool HeartbeatBeforeConnect { get; }

value = messageAdapter.HeartbeatBeforeConnect

Start sending TimeMessage before connection established.

HeartbeatInterval

public TimeSpan HeartbeatInterval { get; set; }

value = messageAdapter.HeartbeatInterval
messageAdapter.HeartbeatInterval = value

接続を追跡するためのサーバーチェック間隔。値はゼロでオフトラッキングです。

Icon

public virtual Uri Icon { get; }

value = messageAdapter.Icon

アイコン

IsAutoReplyOnTransactonalUnsubscription

public virtual bool IsAutoReplyOnTransactonalUnsubscription { get; }

value = messageAdapter.IsAutoReplyOnTransactonalUnsubscription

OrderStatusMessageとPortfolioLookupMessageのサブスクリプションのオートレスポンスを送信します。

IsFullCandlesOnly

public virtual bool IsFullCandlesOnly { get; }

value = messageAdapter.IsFullCandlesOnly

Translates CandleMessage as only fully filled.

IsNativeIdentifiers

public virtual bool IsNativeIdentifiers { get; }

value = messageAdapter.IsNativeIdentifiers

ネイティブ識別子ネイティブでメッセージ内の金融商品を特定します。

IsNativeIdentifiersPersistable

public virtual bool IsNativeIdentifiersPersistable { get; }

value = messageAdapter.IsNativeIdentifiersPersistable

ネイティブ識別子を保存できます。

IsPositionsEmulationRequired

public virtual bool? IsPositionsEmulationRequired { get; }

value = messageAdapter.IsPositionsEmulationRequired

アダプターはエミュレーションPositionChangeMessageを要求しました。

IsReplaceCommandEditCurrent

public virtual bool IsReplaceCommandEditCurrent { get; }

value = messageAdapter.IsReplaceCommandEditCurrent

コマンドは@OrderReplaceMessage@です。

IsSecurityNewsOnly

public virtual bool IsSecurityNewsOnly { get; }

value = messageAdapter.IsSecurityNewsOnly

アダプターは、特定金融商品に関連するニュースを提供します。

IsSupportExecutionsPnL

public virtual bool IsSupportExecutionsPnL { get; }

value = messageAdapter.IsSupportExecutionsPnL

アダプターは@PnL@に記入します。

IsSupportOrderBookIncrements

public virtual bool IsSupportOrderBookIncrements { get; }

value = messageAdapter.IsSupportOrderBookIncrements

アダプターは、増分注文書を翻訳します。

IsSupportSubscriptions

public virtual bool IsSupportSubscriptions { get; }

value = messageAdapter.IsSupportSubscriptions

サブスクリプション(ticks、オーダーブックなど)をサポート

IsSupportTransactionLog

public virtual bool IsSupportTransactionLog { get; }

value = messageAdapter.IsSupportTransactionLog

アダプターは、OrderStatusMessage@の返信に注文の変更を翻訳します。

IterationInterval

public virtual TimeSpan IterationInterval { get; set; }

value = messageAdapter.IterationInterval
messageAdapter.IterationInterval = value

反復との間のインターバル。

LookupTimeout

public virtual TimeSpan? LookupTimeout { get; }

value = messageAdapter.LookupTimeout

タイムアウトを調べる。

MaxParallelMessages

public int MaxParallelMessages { get; set; }

value = messageAdapter.MaxParallelMessages
messageAdapter.MaxParallelMessages = value

処理できるパラレル(非制御)メッセージの最大数を取得またはセットします。 以上または等しい1でなければなりません。

Name

public override string Name { get; set; }

value = messageAdapter.Name
messageAdapter.Name = value

お名前.

NotSupportedResultMessages

public virtual IEnumerable<MessageTypes> NotSupportedResultMessages { get; set; }

value = messageAdapter.NotSupportedResultMessages
messageAdapter.NotSupportedResultMessages = value

アダプターの結果メッセージタイプでは対応しておりません。

OrderConditionType

public virtual Type OrderConditionType { get; }

value = messageAdapter.OrderConditionType

型式:OrderCondition@

Platform

public Platforms Platform { get; protected set; }

value = messageAdapter.Platform
messageAdapter.Platform = value

アダプターを実行できるビット プロセス。

PossibleSupportedMessages

public virtual IEnumerable<MessageTypeInfo> PossibleSupportedMessages { get; set; }

value = messageAdapter.PossibleSupportedMessages
messageAdapter.PossibleSupportedMessages = value

対応可能なメッセージタイプ。

ReConnectionSettings

public ReConnectionSettings ReConnectionSettings { get; }

value = messageAdapter.ReConnectionSettings

接続トラッキング設定IMessageAdapterサーバで

SecurityExtendedFields

public virtual IEnumerable<ValueTuple<string, Type>> SecurityExtendedFields { get; }

value = messageAdapter.SecurityExtendedFields

金融商品分野名をSecurityMessage@に拡張。

StorageName

public virtual string StorageName { get; }

value = messageAdapter.StorageName

保管名。

SupportedInMessages

public virtual IEnumerable<MessageTypes> SupportedInMessages { get; set; }

value = messageAdapter.SupportedInMessages
messageAdapter.SupportedInMessages = value

アダプターメッセージタイプで対応

SupportedMarketDataTypes

internal IEnumerable<DataType> SupportedMarketDataTypes { get; set; }

value = messageAdapter.SupportedMarketDataTypes
messageAdapter.SupportedMarketDataTypes = value

SupportedOrderBookDepths

public virtual IEnumerable<int> SupportedOrderBookDepths { get; }

value = messageAdapter.SupportedOrderBookDepths

Available options for MaxDepth.

TransactionIdGenerator

public IdGenerator TransactionIdGenerator { get; set; }

value = messageAdapter.TransactionIdGenerator
messageAdapter.TransactionIdGenerator = value

内部の子サブスクリプションルーティングに使用されるトランザクションIDジェネレータ。 親アダプターのジェネレータと同期して保存する必要があります。

UseInChannel

public virtual bool UseInChannel { get; }

value = messageAdapter.UseInChannel

メッセージを入力するためのチャンネルを使用します。

UseOutChannel

public virtual bool UseOutChannel { get; }

value = messageAdapter.UseOutChannel

メッセージを発信するためのチャンネルを使用します。

BoardLookupAsync

protected virtual ValueTask BoardLookupAsync(BoardLookupMessage lookupMsg, CancellationToken cancellationToken)

result = messageAdapter.BoardLookupAsync(lookupMsg, cancellationToken)

CancelOrderAsync

protected virtual ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)

result = messageAdapter.CancelOrderAsync(cancelMsg, cancellationToken)

CancelOrderGroupAsync

protected virtual ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)

result = messageAdapter.CancelOrderGroupAsync(cancelMsg, cancellationToken)

ChangePasswordAsync

protected virtual ValueTask ChangePasswordAsync(ChangePasswordMessage pwdMsg, CancellationToken cancellationToken)

result = messageAdapter.ChangePasswordAsync(pwdMsg, cancellationToken)

Clone

public virtual IMessageAdapter Clone()

result = messageAdapter.Clone()

コピーの作成MessageAdapter

戻り値: コピー

ConnectAsync

protected virtual ValueTask ConnectAsync(ConnectMessage connectMsg, CancellationToken cancellationToken)

result = messageAdapter.ConnectAsync(connectMsg, cancellationToken)

CreateOrderLogMarketDepthBuilder

public virtual IOrderLogMarketDepthBuilder CreateOrderLogMarketDepthBuilder(SecurityId securityId)

result = messageAdapter.CreateOrderLogMarketDepthBuilder(securityId)

マーケットデプスビルダーを作成します。

securityId

金融商品ID

戻り値: ログをマーケットデプスビルダーに注文する。

DisconnectAsync

protected virtual ValueTask DisconnectAsync(DisconnectMessage disconnectMsg, CancellationToken cancellationToken)

result = messageAdapter.DisconnectAsync(disconnectMsg, cancellationToken)

GetSupportedMarketDataTypesAsync

public virtual IAsyncEnumerable<DataType> GetSupportedMarketDataTypesAsync(SecurityId securityId, DateTime? from, DateTime? to)

result = messageAdapter.GetSupportedMarketDataTypesAsync(securityId, from, to)

アダプターメッセージタイプでサポートを受ける

securityId

担当: 佐藤 宏

from

リクエストの開始日。 場合は、利用可能なすべてのメッセージが返されます。

to

リクエストの終了日。 場合、利用可能なすべてのメッセージが返されます。

戻り値: アダプター市場データ型で対応

InitMessageLocalTime

private void InitMessageLocalTime(Message message)

messageAdapter.InitMessageLocalTime(message)

ローカルタイムスタンプメッセージの初期化

message

ご挨拶

IsAllDownloadingSupported

public virtual bool IsAllDownloadingSupported(DataType dataType)

result = messageAdapter.IsAllDownloadingSupported(dataType)

対象となる全ての金融商品のダウンロードは有効です。

dataType

データ型情報。

戻り値: 結果をチェックする。

IsSecurityRequired

public virtual bool IsSecurityRequired(DataType dataType)

result = messageAdapter.IsSecurityRequired(dataType)

サブスクリプションのフィルタリング(指定された金融商品のサブスクリプション/サブスクリプションの購読/サブスクリプションの購読)をサポート。

dataType

データ型情報。

戻り値: 結果をチェックする。

IsSupportCandlesPriceLevels

public virtual bool IsSupportCandlesPriceLevels(MarketDataMessage subscription)

result = messageAdapter.IsSupportCandlesPriceLevels(subscription)

キャンドルPriceLevels@を応援します。

subscription

担当: 佐藤 宏

戻り値: 結果をチェックする。

IsSupportCandlesUpdates

public virtual bool IsSupportCandlesUpdates(MarketDataMessage subscription)

result = messageAdapter.IsSupportCandlesUpdates(subscription)

キャンドルのサブスクリプションとライブ更新をサポート。

subscription

担当: 佐藤 宏

戻り値: 結果をチェックする。

Load

public override void Load(SettingsStorage storage)

messageAdapter.Load(storage)

設定をロードします。

storage

設定ストレージ。

MarketDataAsync

protected virtual ValueTask MarketDataAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.MarketDataAsync(mdMsg, cancellationToken)

OnCandlesSubscriptionAsync

protected virtual ValueTask OnCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnCandlesSubscriptionAsync(mdMsg, cancellationToken)

キャンドルデータのサブスクリプションリクエストを処理します。 キャンドルサブスクリプション処理の実装をオーバーライドします。 デフォルト実装はNotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OnLevel1SubscriptionAsync

protected virtual ValueTask OnLevel1SubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnLevel1SubscriptionAsync(mdMsg, cancellationToken)

サブスクリプションリクエストをLevel1データに処理します。Level1サブスクリプション処理の実装をオーバーライドします。デフォルトでは、NotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OnMarketDepthSubscriptionAsync

protected virtual ValueTask OnMarketDepthSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnMarketDepthSubscriptionAsync(mdMsg, cancellationToken)

市場深度データへのサブスクリプションリクエストを処理します。 市場深度サブスクリプション処理の実装をオーバーライドします。 デフォルト実装はNotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OnNewsSubscriptionAsync

protected virtual ValueTask OnNewsSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnNewsSubscriptionAsync(mdMsg, cancellationToken)

サブスクリプションリクエストをリクエストしてニュースデータに処理します。ニュースサブスクリプション処理の実装をオーバーライドします。デフォルトでは、NotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OnOrderLogSubscriptionAsync

protected virtual ValueTask OnOrderLogSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnOrderLogSubscriptionAsync(mdMsg, cancellationToken)

注文ログ(trades/transactions)データに対するサブスクリプションリクエストを処理します。 注文ログサブスクリプション処理の実装をオーバーライドします。 デフォルト実装はNotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OnPropertyChanged

protected void OnPropertyChanged(string propertyName)

messageAdapter.OnPropertyChanged(propertyName)

Raise PropertyChanged event.

propertyName

変更したプロパティの名前。

OnSendInMessageAsync

protected virtual ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapter.OnSendInMessageAsync(message, cancellationToken)

メッセージを送信する ハンドラ。

message

新着情報

cancellationToken

担当: 佐藤 宏

戻り値: 担当: 佐藤 宏

OnTFCandlesSubscriptionAsync

protected virtual ValueTask OnTFCandlesSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnTFCandlesSubscriptionAsync(mdMsg, cancellationToken)

時間枠のキャンドル(TFキャンドル)データのためのサブスクリプションリクエストを処理します。 TFキャンドルサブスクリプション処理の実装をオーバーライドします。 デフォルトの実装はNotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OnTicksSubscriptionAsync

protected virtual ValueTask OnTicksSubscriptionAsync(MarketDataMessage mdMsg, CancellationToken cancellationToken)

result = messageAdapter.OnTicksSubscriptionAsync(mdMsg, cancellationToken)

サブスクリプションリクエストを処理し、データのティックスを処理します。 サブスクリプション処理のティックスへの実装をオーバーライドします。 デフォルトでは、NotSupportedをスローします。

mdMsg

市場データサブスクリプションメッセージ。

cancellationToken

キャンセルトークンで操作をキャンセルします。

戻り値: 同期動作を表すValueTask

OrderStatusAsync

protected virtual ValueTask OrderStatusAsync(OrderStatusMessage statusMsg, CancellationToken cancellationToken)

result = messageAdapter.OrderStatusAsync(statusMsg, cancellationToken)

PortfolioLookupAsync

protected virtual ValueTask PortfolioLookupAsync(PortfolioLookupMessage lookupMsg, CancellationToken cancellationToken)

result = messageAdapter.PortfolioLookupAsync(lookupMsg, cancellationToken)

RegisterOrderAsync

protected virtual ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)

result = messageAdapter.RegisterOrderAsync(regMsg, cancellationToken)

ReplaceOrderAsync

protected virtual ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)

result = messageAdapter.ReplaceOrderAsync(replaceMsg, cancellationToken)

ResetAsync

protected virtual ValueTask ResetAsync(ResetMessage resetMsg, CancellationToken cancellationToken)

result = messageAdapter.ResetAsync(resetMsg, cancellationToken)

Save

public override void Save(SettingsStorage storage)

messageAdapter.Save(storage)

設定を保存します。

storage

設定ストレージ。

SecurityLookupAsync

protected virtual ValueTask SecurityLookupAsync(SecurityLookupMessage lookupMsg, CancellationToken cancellationToken)

result = messageAdapter.SecurityLookupAsync(lookupMsg, cancellationToken)

SendInMessageAsync

public virtual ValueTask SendInMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapter.SendInMessageAsync(message, cancellationToken)

一般的なメッセージを非同期に処理します。

message

処理するメッセージ。

cancellationToken

担当: 佐藤 宏

SendOutConnectionStateAsync

protected ValueTask SendOutConnectionStateAsync(ConnectionStates state, CancellationToken cancellationToken)

result = messageAdapter.SendOutConnectionStateAsync(state, cancellationToken)

接続状態のCancellationToken@に送信してください。

state

担当: 佐藤 宏

cancellationToken

キャンセルトークン。

SendOutDisconnectMessageAsync

protected ValueTask SendOutDisconnectMessageAsync(bool expected, CancellationToken cancellationToken)

result = messageAdapter.SendOutDisconnectMessageAsync(expected, cancellationToken)

送信先のCancellationToken@へ。

expected

切断は期待されます。

cancellationToken

キャンセルトークン。

SendOutDisconnectMessageAsync

protected ValueTask SendOutDisconnectMessageAsync(Exception error, CancellationToken cancellationToken)

result = messageAdapter.SendOutDisconnectMessageAsync(error, cancellationToken)

送信先のCancellationToken@へ。

error

エラー情報。 .

cancellationToken

キャンセルトークン。

SendOutErrorAsync

protected ValueTask SendOutErrorAsync(string description, CancellationToken cancellationToken)

result = messageAdapter.SendOutErrorAsync(description, cancellationToken)

新規のメッセージErrorMessageを初期化し、CancellationTokenに渡します。

description

エラーの詳細。

cancellationToken

キャンセルトークン。

SendOutErrorAsync

protected ValueTask SendOutErrorAsync(Exception error, CancellationToken cancellationToken)

result = messageAdapter.SendOutErrorAsync(error, cancellationToken)

新規のメッセージErrorMessageを初期化し、CancellationTokenに渡します。

error

エラーの詳細。

cancellationToken

キャンセルトークン。

SendOutMessageAsync

public virtual ValueTask SendOutMessageAsync(Message message, CancellationToken cancellationToken)

result = messageAdapter.SendOutMessageAsync(message, cancellationToken)

発信メッセージ(状態変更、注文など)を送信します。

message

ご挨拶

cancellationToken

担当: 佐藤 宏

SendSubscriptionFinishedAsync

protected ValueTask SendSubscriptionFinishedAsync(long originalTransactionId, CancellationToken cancellationToken, DateTime? nextFrom)

result = messageAdapter.SendSubscriptionFinishedAsync(originalTransactionId, cancellationToken, nextFrom)

新規のメッセージSubscriptionFinishedMessageを初期化し、CancellationTokenに渡します。

originalTransactionId

メッセージを返すメッセージの元のメッセージのID。

cancellationToken

キャンセルトークン。

nextFrom

代表取締役社長 佐藤 浩

SendSubscriptionNotSupportedAsync

protected ValueTask SendSubscriptionNotSupportedAsync(long originalTransactionId, CancellationToken cancellationToken)

result = messageAdapter.SendSubscriptionNotSupportedAsync(originalTransactionId, cancellationToken)

新規のメッセージSubscriptionResponseMessageを初期化し、CancellationTokenに渡します。

originalTransactionId

メッセージを返すメッセージの元のメッセージのID。

cancellationToken

キャンセルトークン。

SendSubscriptionOnlineAsync

protected ValueTask SendSubscriptionOnlineAsync(long originalTransactionId, CancellationToken cancellationToken)

result = messageAdapter.SendSubscriptionOnlineAsync(originalTransactionId, cancellationToken)

新規のメッセージSubscriptionOnlineMessageを初期化し、CancellationTokenに渡します。

originalTransactionId

メッセージを返すメッセージの元のメッセージのID。

cancellationToken

キャンセルトークン。

SendSubscriptionReplyAsync

protected ValueTask SendSubscriptionReplyAsync(long originalTransactionId, CancellationToken cancellationToken, Exception error)

result = messageAdapter.SendSubscriptionReplyAsync(originalTransactionId, cancellationToken, error)

新規のメッセージSubscriptionResponseMessageを初期化し、CancellationTokenに渡します。

originalTransactionId

メッセージを返すメッセージの元のメッセージのID。

cancellationToken

キャンセルトークン。

error

エラー情報を登録または退会します。 回答がない場合に設定します。

SendSubscriptionResultAsync

protected ValueTask SendSubscriptionResultAsync(ISubscriptionMessage message, CancellationToken cancellationToken)

result = messageAdapter.SendSubscriptionResultAsync(message, cancellationToken)

新規のメッセージSubscriptionOnlineMessageまたはSubscriptionFinishedMessageを初期化し、CancellationTokenに渡します。

message

サブスクリプション。

cancellationToken

キャンセルトークン。

TimeAsync

protected virtual ValueTask TimeAsync(TimeMessage timeMsg, CancellationToken cancellationToken)

result = messageAdapter.TimeAsync(timeMsg, cancellationToken)

ValidateSecurityId

protected virtual bool ValidateSecurityId(SecurityId secId)

result = messageAdapter.ValidateSecurityId(secId)

指定された金融商品IDをアダプターで有効化し、サブスクリプションを実行できます。

secId

代表取締役社長 佐藤 浩

戻り値: 結果をチェックする。

NewOutMessageAsync

public event Func<Message, CancellationToken, ValueTask> NewOutMessageAsync

messageAdapter.NewOutMessageAsync += handler

新規メッセージイベント