SubscriptionManager

SubscriptionManager

public SubscriptionManager(ILogReceiver logReceiver, IdGenerator transactionIdGenerator, Func<Message> createProcessSuspendedMessage, ISubscriptionManagerState state)

subscriptionManager = SubscriptionManager(logReceiver, transactionIdGenerator, createProcessSuspendedMessage, state)

Aplicação de processamento de mensagens de assinatura.

logReceiver

Receptor de registo.

transactionIdGenerator

Gerador de identificação de transação.

createProcessSuspendedMessage

Criar uma mensagem que retoma o processamento após as assinaturas remapeadas são em espera.

state

Armazém estatal.

State

public ISubscriptionManagerState State { get; }

value = subscriptionManager.State

Armazém estatal.

ProcessInMessage

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

result = subscriptionManager.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<Message, Message[]> ProcessOutMessage(Message message)

result = subscriptionManager.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.