IProtocolServer
Interface comum para servidores de protocolo (FIX, SBE, etc.). Fornece API unificada para executar o servidor e rotear mensagens.
Implementa: ILogReceiver, ILogSource, IDisposable
Propriedades
public IEnumerable<IMessageListenerSession> Sessions { get; }
value = iProtocolServer.Sessions
Imagem de todas as sessões de cliente atualmente realizadas pelo servidor. Útil para testes que precisam verificar a contabilidade do lado do servidor independentemente do que o adaptador do cliente acontece para ver (um adaptador FIX, por exemplo, se reconecta silenciosamente após um pontapé no lado do servidor, de modo que o lado do cliente DisconnectMessagenão é um sinal confiável).
Métodos
public IAsyncEnumerable<ValueTuple<IMessageListenerSession, Message>> RunAsync(CancellationToken cancellationToken)
result = iProtocolServer.RunAsync(cancellationToken)
Execute o servidor e forneça mensagens recebidas de clientes conectados.
public bool SendInMessage(Message message)
result = iProtocolServer.SendInMessage(message)
Enviar uma mensagem do módulo servidor para clientes conectados.
public bool SendInMessage(IMessageListenerSession session, Message message)
result = iProtocolServer.SendInMessage(session, message)
Enviar uma mensagem para uma sessão específica do cliente. A implementação por omissão ignora a sessão e as transmissões.