IProtocolServer

StockSharp.Server.Core

Interface comum para servidores de protocolo (FIX, SBE, etc.). Fornece API unificada para executar o servidor e rotear mensagens.

Implementa: ILogReceiver, ILogSource, IDisposable

Propriedades

Sessions
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).

State
public ChannelStates State { get; }
value = iProtocolServer.State

Estado atual do servidor.

Métodos

RunAsync
public IAsyncEnumerable<ValueTuple<IMessageListenerSession, Message>> RunAsync(CancellationToken cancellationToken)
result = iProtocolServer.RunAsync(cancellationToken)

Execute o servidor e forneça mensagens recebidas de clientes conectados.

SendInMessage
public bool SendInMessage(Message message)
result = iProtocolServer.SendInMessage(message)

Enviar uma mensagem do módulo servidor para clientes conectados.

SendInMessage
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.