FixServer

StockSharp.Server.Fix

FIX server.

继承自: BaseProtocolServer<ClientFixSession, FixServerSubscription, FixServerSettings>

构造函数

FixServer(IAuthorization, ITransactionIdStorage, string, Type)

Initializes a new instance of the FixServer.

authorization: The customer authentication.
transactionIdStorage: Transaction and request identifiers storage.
licenseFeatureId: LicenseFeatureId
componentType: ComponentTimestamp

FixServer(IAuthorization, ITransactionIdStorage, string, DateTime, IMessageConverter)

Initializes a new instance of the FixServer.

authorization: The customer authentication.
transactionIdStorage: Transaction and request identifiers storage.
licenseFeatureId: LicenseFeatureId
componentTimestamp: ComponentTimestamp
converter: Message converter.

属性

Authorization : IAuthorization

The customer authentication.

ComponentTimestamp : DateTime

Component timestamp.

Converter : IMessageConverter

Message converter for FIX ↔ StockSharp message conversion.

LicenseFeatureId : string

License feature id to be sent as Logon response.

SendOutHeartbeats : bool

Send heartbeat via outgoing messages channel.

TransactionIdStorage : ITransactionIdStorage

方法

CreateCondition() : OrderCondition

To create the order condition.

返回值: The order condition.

CreateSubscription(ClientFixSession, string, ServerSubscription, MessageTypes) : FixServerSubscription

CreateTransactionId(ClientFixSession, string) : long

Generate a new request identifier.

session: Session.
requestId: Request identifier.

返回值: Transaction ID.

GetSessionKey(ClientFixSession) : string

IsStubSubscription(FixServerSubscription) : bool

Load(SettingsStorage)

Load settings.

storage: Settings storage.

OnClearListenerState()

Clear protocol-specific listener state (stop listeners, etc.).

OnProcess(FixSession, string, IFixReader, CancellationToken) : IAsyncEnumerable<Message>

The method is called when the received message is processing.

OnStartListeners(CancellationToken)

Start protocol-specific listeners (TCP, etc.). Add tasks to _backgroundTasks.

PostInitCondition(char, OrderCondition)

The final initialization of the order condition.

ordType: Order type.
condition: The order condition.

ProcessInMessage(Message, CancellationToken)

Process an incoming message and route to subscribed clients.

ProcessLogout(ClientFixSession)

ReadOrderConditionAsync(IFixServerSerializer, FixTags, Func<OrderCondition>, CancellationToken) : ValueTask<bool>

To read the order condition OrderCondition.

serializer: IFixServerSerializer
tag: Tag.
getCondition: The function returning the order condition.
cancellationToken: CancellationToken

返回值: Whether the data was successfully processed.

Save(SettingsStorage)

Save settings.

storage: Settings storage.

ScheduleSessionWork(ClientFixSession, ServerSubscription, string, Func<ClientFixSession, string, CancellationToken, ValueTask<bool>>)

TryGetRequestId(ClientFixSession, long) : string

Get the request identifier.

session: The session.
transactionId: Transaction ID.

返回值: Request identifier.

TryResolveTransactionId(ISessionTransactionIdStorage, string, long) : bool

Resolve a client request id to a server transaction id.

storage: The session transaction id storage.
requestId: The request identifier.
transactionId: The resolved transaction ID.

返回值: if the transaction ID was resolved; otherwise, .

WriterFixOrderConditionAsync(IFixServerSerializer, OrderCondition, CancellationToken) : ValueTask

To record data by the order condition (async version).

serializer: IFixServerSerializer
condition: Order condition (e.g., stop- and algo- orders parameters).
cancellationToken: Cancellation token.