IProtocolServer
Gemeinsame Schnittstelle für Protokollserver (FIX, SBE usw.): Bietet einheitliche API für den Betrieb des Servers und Routing-Nachrichten.
Implementiert: ILogReceiver, ILogSource, IDisposable
Eigenschaften
public IEnumerable<IMessageListenerSession> Sessions { get; }
value = iProtocolServer.Sessions
Eine Momentaufnahme aller Client-Sitzungen, die derzeit vom Server durchgeführt werden. Nützlich für Tests, die die serverseitige Sitzungsbuchhaltung unabhängig davon überprüfen müssen, was der Client-Adapter zufällig sieht (ein FIX-Adapter verbindet sich beispielsweise nach einem serverseitigen Kick automatisch wieder, so dass das clientseitige DisconnectMessage kein zuverlässiges Signal ist).
Methoden
public IAsyncEnumerable<ValueTuple<IMessageListenerSession, Message>> RunAsync(CancellationToken cancellationToken)
result = iProtocolServer.RunAsync(cancellationToken)
Führen Sie den Server aus und geben Sie eingehende Nachrichten von verbundenen Clients ab.
public bool SendInMessage(Message message)
result = iProtocolServer.SendInMessage(message)
Senden Sie eine Nachricht vom Servermodul an verbundene Clients.
public bool SendInMessage(IMessageListenerSession session, Message message)
result = iProtocolServer.SendInMessage(session, message)
Senden Sie eine Nachricht an eine bestimmte Clientsitzung. Standardimplementierung ignoriert Sitzung und Sendungen.