OfflineManager

OfflineManager

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

offlineManager = OfflineManager(logReceiver, createProcessSuspendedMessage, state)

Implementação de processamento de mensagens offline.

logReceiver

Receptor de registo.

createProcessSuspendedMessage

Crie uma mensagem que retoma o processamento após a restauração da conexão.

state

Armazém estatal.

MaxMessageCount

public int MaxMessageCount { get; set; }

value = offlineManager.MaxMessageCount
offlineManager.MaxMessageCount = value

Número máximo de filas de mensagens.

ProcessInMessage

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

result = offlineManager.ProcessInMessage(message)

Processe uma mensagem entrando no adaptador interno.

message

Mensagem a chegar.

Retorna: Processando o resultado com mensagens para mensagens de saída e para o encaminhamento.

ProcessOutMessage

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

result = offlineManager.ProcessOutMessage(message)

Processe uma mensagem vinda do adaptador interno.

message

Mensagem de saída.

Retorna: Processando resultado com mensagem de saída e mensagens de saída extra.