CandleBuilderManager

CandleBuilderManager

public CandleBuilderManager(ILogReceiver logReceiver, IdGenerator idGenerator, IMessageAdapterWrapper adapter, bool sendFinishedCandlesImmediatelly, IStorageBuffer buffer, bool cloneOutCandles, CandleBuilderProvider candleBuilderProvider)

candleBuilderManager = CandleBuilderManager(logReceiver, idGenerator, adapter, sendFinishedCandlesImmediatelly, buffer, cloneOutCandles, candleBuilderProvider)

Initialisiert eine neue Instanz von CandleBuilderManager.

logReceiver

Protokollempfänger.

idGenerator

Transaktions-ID-Generator.

adapter

Adapter-Wrapper für Loopback-Nachrichten und inneren Adapterzugriff.

sendFinishedCandlesImmediatelly

Schicken Sie sofort fertige Kerzen.

buffer

Speicherpuffer.

cloneOutCandles

Gibt an, ob ausgehende Kerzen vor dem Aussenden geklont werden sollten.

candleBuilderProvider

Candle Builders Anbieter.

Buffer

public IStorageBuffer Buffer { get; set; }

value = candleBuilderManager.Buffer
candleBuilderManager.Buffer = value

Speicherpuffer.

SendFinishedCandlesImmediatelly

public bool SendFinishedCandlesImmediatelly { get; set; }

value = candleBuilderManager.SendFinishedCandlesImmediatelly
candleBuilderManager.SendFinishedCandlesImmediatelly = value

Senden Sie fertige Kerzen, wenn sie erhalten haben.

ProcessInMessageAsync

public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderManager.ProcessInMessageAsync(message, cancellationToken)

Verarbeiten Sie eine Nachricht, die in den inneren Adapter gelangt.

message

Eingehende Nachricht.

cancellationToken

Löschungszeichen.

Rückgabe: Verarbeitungsergebnis.

ProcessOutMessageAsync

public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderManager.ProcessOutMessageAsync(message, cancellationToken)

Verarbeiten Sie eine Nachricht, die vom inneren Adapter kommt.

message

Abgehende Nachricht.

cancellationToken

Löschungszeichen.

Rückgabe: Verarbeitungsergebnis.