FixServer

FixServer

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, Type componentType)

fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentType)

FixServer の新規インスタンスを初期化します。

authorization

顧客の認証。

transactionIdStorage

トランザクションと識別リクエストのストレージ。

licenseFeatureId

担当: 佐藤 宏

componentType

担当: 佐藤 宏

FixServer

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, DateTime componentTimestamp, IMessageConverter converter)

fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentTimestamp, converter)

FixServer の新規インスタンスを初期化します。

authorization

顧客の認証。

transactionIdStorage

トランザクションと識別リクエストのストレージ。

licenseFeatureId

担当: 佐藤 宏

componentTimestamp

担当: 佐藤 宏

converter

メッセージコンバーター。

Authorization

public IAuthorization Authorization { get; }

value = fixServer.Authorization

顧客の認証。

ComponentTimestamp

public DateTime ComponentTimestamp { get; }

value = fixServer.ComponentTimestamp

コンポーネントタイムスタンプ。

Converter

public IMessageConverter Converter { get; }

value = fixServer.Converter

FIX ⇔ StockSharp@メッセージ変換用メッセージコンバーター

LicenseFeatureId

public string LicenseFeatureId { get; }

value = fixServer.LicenseFeatureId

ライセンス機能 ログオン応答として送信されるID。

SendOutHeartbeats

public bool SendOutHeartbeats { get; set; }

value = fixServer.SendOutHeartbeats
fixServer.SendOutHeartbeats = value

発信メッセージチャネルでハートビートを送信します。

TransactionIdStorage

public ITransactionIdStorage TransactionIdStorage { get; }

value = fixServer.TransactionIdStorage

CreateCondition

protected virtual OrderCondition CreateCondition()

result = fixServer.CreateCondition()

注文条件を作成するため。

戻り値: 注文条件。

CreateSubscription

protected override FixServerSubscription CreateSubscription(ClientFixSession session, string requestId, ServerSubscription subscription, MessageTypes type)

result = fixServer.CreateSubscription(session, requestId, subscription, type)

CreateTransactionId

private long CreateTransactionId(ClientFixSession session, string requestId)

result = fixServer.CreateTransactionId(session, requestId)

新規リクエスト識別子を生成します。

session

セッション

requestId

識別子をリクエストする。

戻り値: 取引ID。

GetSessionKey

protected override string GetSessionKey(ClientFixSession session)

result = fixServer.GetSessionKey(session)

IsStubSubscription

protected override bool IsStubSubscription(FixServerSubscription subscription)

result = fixServer.IsStubSubscription(subscription)

Load

public override void Load(SettingsStorage storage)

fixServer.Load(storage)

設定をロードします。

storage

設定ストレージ。

OnClearListenerState

protected override void OnClearListenerState()

fixServer.OnClearListenerState()

明確なプロトコル固有のリスナー状態(停止リスナーなど)。

OnProcess

protected virtual IAsyncEnumerable<Message> OnProcess(FixSession session, string msgType, IFixReader reader, CancellationToken cancellationToken)

result = fixServer.OnProcess(session, msgType, reader, cancellationToken)

受信したメッセージが処理されると呼び出されます。

OnStartListeners

protected override void OnStartListeners(CancellationToken cancellationToken)

fixServer.OnStartListeners(cancellationToken)

プロトコル固有のリスナー(TCPなど)を開始します。_backgroundTasksにタスクを追加します。

PostInitCondition

protected virtual void PostInitCondition(char ordType, OrderCondition condition)

fixServer.PostInitCondition(ordType, condition)

注文条件の最終初期化。

ordType

注文タイプ。

condition

注文条件。

ProcessInMessage

protected override void ProcessInMessage(Message message, CancellationToken cancellationToken)

fixServer.ProcessInMessage(message, cancellationToken)

顧客を購読するメッセージとルートを処理する。

ProcessLogout

protected override void ProcessLogout(ClientFixSession session)

fixServer.ProcessLogout(session)

ReadOrderConditionAsync

protected virtual ValueTask<bool> ReadOrderConditionAsync(IFixServerSerializer serializer, FixTags tag, Func<OrderCondition> getCondition, CancellationToken cancellationToken)

result = fixServer.ReadOrderConditionAsync(serializer, tag, getCondition, cancellationToken)

注文条件OrderCondition@を読んで下さい。

serializer

担当: 佐藤 宏

tag

キーワード

getCondition

注文条件を戻す機能。

cancellationToken

担当: 佐藤 宏

戻り値: データの処理が成功しているかどうか。

Save

public override void Save(SettingsStorage storage)

fixServer.Save(storage)

設定を保存します。

storage

設定ストレージ。

ScheduleSessionWork

protected override void ScheduleSessionWork(ClientFixSession session, ServerSubscription subscription, string requestId, Func<ClientFixSession, string, CancellationToken, ValueTask<bool>> handler)

fixServer.ScheduleSessionWork(session, subscription, requestId, handler)

TryGetRequestId

private static string TryGetRequestId(ClientFixSession session, long transactionId)

result = FixServer.TryGetRequestId(session, transactionId)

識別リクエストを取得します。

session

セッション。

transactionId

取引ID。

戻り値: 識別子をリクエストする。

TryResolveTransactionId

internal static bool TryResolveTransactionId(ISessionTransactionIdStorage storage, string requestId, long transactionId)

result = FixServer.TryResolveTransactionId(storage, requestId, transactionId)

クライアントリクエスト ID をサーバートランザクション ID に解決します。

storage

セッショントランザクションIDストレージ。

requestId

識別子のリクエスト。

transactionId

解決されたトランザクションID。

戻り値: トランザクション ID が解決した場合は、 .

WriterFixOrderConditionAsync

protected virtual ValueTask WriterFixOrderConditionAsync(IFixServerSerializer serializer, OrderCondition condition, CancellationToken cancellationToken)

result = fixServer.WriterFixOrderConditionAsync(serializer, condition, cancellationToken)

注文条件(非同期版)でデータを記録する。

serializer

担当: 佐藤 宏

condition

注文条件(e.g.、停止およびalgo-の発注変数)。

cancellationToken

キャンセルトークン。