OfflineManager

OfflineManager

public OfflineManager(ILogReceiver logReceiver, Func<Message> createProcessSuspendedMessage, IOfflineManagerState state)

offlineManager = OfflineManager(logReceiver, createProcessSuspendedMessage, state)

Implementierung der Offline-Nachrichtenverarbeitung.

logReceiver

Protokollempfänger.

createProcessSuspendedMessage

Erstellen Sie eine Nachricht, die die Verarbeitung nach Wiederherstellung der Verbindung wiederaufnimmt.

state

staatliche Lagerung.

MaxMessageCount

public int MaxMessageCount { get; set; }

value = offlineManager.MaxMessageCount
offlineManager.MaxMessageCount = value

Max Nachrichten-Warteschlange zählen.

ProcessInMessage

public ValueTuple<Message[], Message[], bool> ProcessInMessage(Message message)

result = offlineManager.ProcessInMessage(message)

Verarbeiten Sie eine Nachricht, die in den inneren Adapter gelangt.

message

Eingehende Nachricht.

Rückgabe: Verarbeitungsergebnis mit Nachrichten zu Weiterleitungs- und Ausgabenachrichten.

ProcessOutMessage

public ValueTuple<bool, Message[]> ProcessOutMessage(Message message)

result = offlineManager.ProcessOutMessage(message)

Verarbeiten Sie eine Nachricht, die vom inneren Adapter kommt.

message

Abgehende Nachricht.

Rückgabe: Verarbeitungsergebnis mit Vorwärtsnachricht und zusätzlichen Ausgabenachrichten.