IProtocolServer
Interfaz común para servidores de protocolo (FIX, SBE, etc.) Proporciona API unificada para ejecutar el servidor y los mensajes de enrutamiento.
Implementa: ILogReceiver, ILogSource, IDisposable
Propiedades
public IEnumerable<IMessageListenerSession> Sessions { get; }
value = iProtocolServer.Sessions
Captura de todas las sesiones del cliente que actualmente tiene el servidor. Útil para pruebas que necesitan verificar el mantenimiento de la sesión del servidor independientemente de lo que el adaptador del cliente pasa a ver (un adaptador FIX, por ejemplo, silenciosamente auto-reconectado después de una patada del lado del servidor, por lo que el cliente DisconnectMessage no es una señal confiable).
Métodos
public IAsyncEnumerable<ValueTuple<IMessageListenerSession, Message>> RunAsync(CancellationToken cancellationToken)
result = iProtocolServer.RunAsync(cancellationToken)
Ejecute el servidor y obtenga mensajes entrantes de clientes conectados.
public bool SendInMessage(Message message)
result = iProtocolServer.SendInMessage(message)
Enviar un mensaje desde el módulo servidor a clientes conectados.
public bool SendInMessage(IMessageListenerSession session, Message message)
result = iProtocolServer.SendInMessage(session, message)
Enviar un mensaje a una sesión de clientes específica. La implementación predeterminada ignora la sesión y las transmisiones.