SubscriptionManager

SubscriptionManager

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

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

サブスクリプションメッセージ処理の実装。

logReceiver

ログ受信機。

transactionIdGenerator

トランザクションIDジェネレータ。

createProcessSuspendedMessage

再マップされたサブスクリプションが続いた後に処理を再開するメッセージを作成します。

state

状態の貯蔵。

State

public ISubscriptionManagerState State { get; }

value = subscriptionManager.State

状態の貯蔵。

ProcessInMessage

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

result = subscriptionManager.ProcessInMessage(message)

内側のアダプターにメッセージが入ります。

message

投稿する

戻り値: メッセージで結果を処理してメッセージを転送し、メッセージを出力します。

ProcessOutMessage

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

result = subscriptionManager.ProcessOutMessage(message)

インナーアダプターからメッセージが届くようにします。

message

メッセージを発信する。

戻り値: 転送メッセージと出力メッセージの余分な処理結果。