FixServer

StockSharp.Server.Fix

Servidor FIX.

Hereda de: BaseProtocolServer<ClientFixSession, FixServerSubscription, FixServerSettings>

Constructores

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

Inicia una nueva instancia de la FixServer.

authorization
La autenticación del cliente.
transactionIdStorage
Almacenamiento de identificadores de transacciones y solicitudes.
licenseFeatureId
LicenseFeatureId
componentType
ComponentTimestamp
FixServer
public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, DateTime componentTimestamp, IMessageConverter converter)
fixServer = FixServer(authorization, transactionIdStorage, licenseFeatureId, componentTimestamp, converter)

Inicia una nueva instancia de la FixServer.

authorization
La autenticación del cliente.
transactionIdStorage
Almacenamiento de identificadores de transacciones y solicitudes.
licenseFeatureId
LicenseFeatureId
componentTimestamp
ComponentTimestamp
converter
Conversor de mensajes.

Propiedades

Authorization
public IAuthorization Authorization { get; }
value = fixServer.Authorization

La autenticación del cliente.

ComponentTimestamp
public DateTime ComponentTimestamp { get; }
value = fixServer.ComponentTimestamp

Timetamp de componente.

Converter
public IMessageConverter Converter { get; }
value = fixServer.Converter

Conversor de mensajes para la conversión de mensajes FIX ↔ StockSharp.

LicenseFeatureId
public string LicenseFeatureId { get; }
value = fixServer.LicenseFeatureId

La función de licencia id se envía como respuesta Logon.

SendOutHeartbeats
public bool SendOutHeartbeats { get; set; }
value = fixServer.SendOutHeartbeats
fixServer.SendOutHeartbeats = value

Envía latidos cardíacos a través de canales de mensajes salientes.

TransactionIdStorage
public ITransactionIdStorage TransactionIdStorage { get; }
value = fixServer.TransactionIdStorage

Métodos

CreateCondition
protected virtual OrderCondition CreateCondition()
result = fixServer.CreateCondition()

Para crear la condición de pedido.

Devuelve: La condición de orden.

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)

Genera un nuevo identificador de solicitud.

session
Sesión.
requestId
Solicito identificador.

Devuelve: ID de transacción.

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)

Ajustes de carga.

storage
Configuración de almacenamiento.
OnClearListenerState
protected override void OnClearListenerState()
fixServer.OnClearListenerState()

Estado de escucha específico del protocolo claro (detener a los oyentes, etc.).

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

El método se llama cuando el mensaje recibido es procesado.

OnStartListeners
protected override void OnStartListeners(CancellationToken cancellationToken)
fixServer.OnStartListeners(cancellationToken)

Comience los oyentes específicos del protocolo (TCP, etc.) Agregue tareas a _backgroundTasks.

PostInitCondition
protected virtual void PostInitCondition(char ordType, OrderCondition condition)
fixServer.PostInitCondition(ordType, condition)

La inicialización final de la condición de pedido.

ordType
Tipo de pedido.
condition
La condición de orden.
ProcessInMessage
protected override void ProcessInMessage(Message message, CancellationToken cancellationToken)
fixServer.ProcessInMessage(message, cancellationToken)

Procesar un mensaje entrante y una ruta para clientes suscritos.

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)

Para leer la condición de pedido OrderCondition.

serializer
IFixServerSerializer
tag
Tag.
getCondition
La función que devolverá la condición de pedido.
cancellationToken
CancellationToken

Devuelve: Si los datos se procesan con éxito.

Save
public override void Save(SettingsStorage storage)
fixServer.Save(storage)

Guardar configuración.

storage
Configuración de almacenamiento.
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)

Consigue el identificador de solicitud.

session
El período de sesiones.
transactionId
ID de transacción.

Devuelve: Solicito identificador.

TryResolveTransactionId
internal static bool TryResolveTransactionId(ISessionTransactionIdStorage storage, string requestId, long transactionId)
result = FixServer.TryResolveTransactionId(storage, requestId, transactionId)

Resolver una solicitud de cliente id a una transacción de servidor id.

storage
El almacenamiento de la transacción de sesión id.
requestId
El identificador de solicitud.
transactionId
El ID de transacción resuelto.

Devuelve: si el ID de transacción fue resuelto; de lo contrario, .

WriterFixOrderConditionAsync
protected virtual ValueTask WriterFixOrderConditionAsync(IFixServerSerializer serializer, OrderCondition condition, CancellationToken cancellationToken)
result = fixServer.WriterFixOrderConditionAsync(serializer, condition, cancellationToken)

Para registrar datos por la condición de pedido (versión asinc).

serializer
IFixServerSerializer
condition
Condiciones de pedido (e.g@., parada y algo-).
cancellationToken
Cancelación token.