Package energy.eddie.aiida.adapters.datasource.inbound.ack

Class InboundAcknowledgementStreamer

java.lang.Object

energy.eddie.aiida.adapters.datasource.inbound.ack.InboundAcknowledgementStreamer

public class InboundAcknowledgementStreamer
extends Object

Constructor Summary

Constructors

Constructor	Description
InboundAcknowledgementStreamer(UUID aiidaId, tools.jackson.databind.ObjectMapper objectMapper, String acknowledgementTopic, reactor.core.publisher.Flux<InboundRecord> inboundRecordFlux)
InboundAcknowledgementStreamer(UUID aiidaId, tools.jackson.databind.ObjectMapper objectMapper, String acknowledgementTopic, reactor.core.publisher.Flux<InboundRecord> inboundRecordFlux, AckFormatterStrategyRegistry ackFormatterStrategyRegistry)

Method Summary

Modifier and Type	Method	Description
void	start(org.eclipse.paho.mqttv5.client.IMqttAsyncClient mqttClient)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InboundAcknowledgementStreamer

public InboundAcknowledgementStreamer(UUID aiidaId,
 tools.jackson.databind.ObjectMapper objectMapper,
 @Nullable
 String acknowledgementTopic,
 reactor.core.publisher.Flux<InboundRecord> inboundRecordFlux)

InboundAcknowledgementStreamer

public InboundAcknowledgementStreamer(UUID aiidaId,
 tools.jackson.databind.ObjectMapper objectMapper,
 @Nullable
 String acknowledgementTopic,
 reactor.core.publisher.Flux<InboundRecord> inboundRecordFlux,
 AckFormatterStrategyRegistry ackFormatterStrategyRegistry)

Method Details

start

public void start(@Nullable
 org.eclipse.paho.mqttv5.client.IMqttAsyncClient mqttClient)