FixServer
Servidor FIX.
Hereda de: BaseProtocolServer<ClientFixSession, FixServerSubscription, FixServerSettings>
Constructores
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
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
public IAuthorization Authorization { get; }
value = fixServer.Authorization
La autenticación del cliente.
public DateTime ComponentTimestamp { get; }
value = fixServer.ComponentTimestamp
Timetamp de componente.
public IMessageConverter Converter { get; }
value = fixServer.Converter
Conversor de mensajes para la conversión de mensajes FIX ↔ StockSharp.
public string LicenseFeatureId { get; }
value = fixServer.LicenseFeatureId
La función de licencia id se envía como respuesta Logon.
public bool SendOutHeartbeats { get; set; }
value = fixServer.SendOutHeartbeats
fixServer.SendOutHeartbeats = value
Envía latidos cardíacos a través de canales de mensajes salientes.
public ITransactionIdStorage TransactionIdStorage { get; }
value = fixServer.TransactionIdStorage
Métodos
protected virtual OrderCondition CreateCondition()
result = fixServer.CreateCondition()
Para crear la condición de pedido.
Devuelve: La condición de orden.
protected override FixServerSubscription CreateSubscription(ClientFixSession session, string requestId, ServerSubscription subscription, MessageTypes type)
result = fixServer.CreateSubscription(session, requestId, subscription, type)
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.
protected override string GetSessionKey(ClientFixSession session)
result = fixServer.GetSessionKey(session)
protected override bool IsStubSubscription(FixServerSubscription subscription)
result = fixServer.IsStubSubscription(subscription)
public override void Load(SettingsStorage storage)
fixServer.Load(storage)
Ajustes de carga.
- storage
- Configuración de almacenamiento.
protected override void OnClearListenerState()
fixServer.OnClearListenerState()
Estado de escucha específico del protocolo claro (detener a los oyentes, etc.).
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.
protected override void OnStartListeners(CancellationToken cancellationToken)
fixServer.OnStartListeners(cancellationToken)
Comience los oyentes específicos del protocolo (TCP, etc.) Agregue tareas a _backgroundTasks.
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.
protected override void ProcessInMessage(Message message, CancellationToken cancellationToken)
fixServer.ProcessInMessage(message, cancellationToken)
Procesar un mensaje entrante y una ruta para clientes suscritos.
protected override void ProcessLogout(ClientFixSession session)
fixServer.ProcessLogout(session)
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.
public override void Save(SettingsStorage storage)
fixServer.Save(storage)
Guardar configuración.
- storage
- Configuración de almacenamiento.
protected override void ScheduleSessionWork(ClientFixSession session, ServerSubscription subscription, string requestId, Func<ClientFixSession, string, CancellationToken, ValueTask<bool>> handler)
fixServer.ScheduleSessionWork(session, subscription, requestId, handler)
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.
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, .
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.