SubscriptionManager

SubscriptionManager

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

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

Aplicación de procesamiento de mensajes de suscripción.

logReceiver

Receptor de registro.

transactionIdGenerator

Generador de identificación de transacciones.

createProcessSuspendedMessage

Cree un mensaje que reanude el procesamiento después de que se rematan las suscripciones se encuerden.

state

Almacenamiento estatal.

State

public ISubscriptionManagerState State { get; }

value = subscriptionManager.State

Almacenamiento estatal.

ProcessInMessage

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

result = subscriptionManager.ProcessInMessage(message)

Procesar un mensaje entrando en el adaptador interno.

message

Mensaje entrante.

Devuelve: Resultado de procesamiento con mensajes de salida y mensajes de salida.

ProcessOutMessage

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

result = subscriptionManager.ProcessOutMessage(message)

Procesar un mensaje que viene del adaptador interno.

message

Mensaje saliente.

Devuelve: Resultado de procesamiento con mensajes de mensaje y mensajes de salida adicionales.