OfflineManager

OfflineManager

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

offlineManager = OfflineManager(logReceiver, createProcessSuspendedMessage, state)

Реализация автономной обработки сообщений.

logReceiver

Приемник журналов.

createProcessSuspendedMessage

Создайте сообщение, обработка которого возобновляется после восстановления соединения.

state

Государственное хранилище.

MaxMessageCount

public int MaxMessageCount { get; set; }

value = offlineManager.MaxMessageCount
offlineManager.MaxMessageCount = value

Макс, очередь сообщений.

ProcessInMessage

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

result = offlineManager.ProcessInMessage(message)

Обработать сообщение, поступающее во внутренний адаптер.

message

Входящее сообщение.

Возвращает: Результат обработки с сообщениями для пересылки и вывода сообщений.

ProcessOutMessage

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

result = offlineManager.ProcessOutMessage(message)

Обработать сообщение, поступающее от внутреннего адаптера.

message

Исходящее сообщение.

Возвращает: Результат обработки с пересылаемым сообщением и дополнительными выходными сообщениями.