OfflineManager

OfflineManager

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

offlineManager = OfflineManager(logReceiver, createProcessSuspendedMessage, state)

Offline message processing implementation.

logReceiver

Log receiver.

createProcessSuspendedMessage

Create a message that resumes processing after connection is restored.

state

State storage.

MaxMessageCount

public int MaxMessageCount { get; set; }

value = offlineManager.MaxMessageCount
offlineManager.MaxMessageCount = value

Max message queue count.

ProcessInMessage

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

result = offlineManager.ProcessInMessage(message)

Process a message going into the inner adapter.

message

Incoming message.

Returns: Processing result: toInner messages to forward, toOut messages to emit, shouldForward indicates if original should be sent.

ProcessOutMessage

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

result = offlineManager.ProcessOutMessage(message)

Process a message coming from the inner adapter.

message

Outgoing message.

Returns: Processing result: forward indicates if message should be forwarded, extraOut additional messages to emit, suppressOriginal if original should not be forwarded.