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

Class InboundAcknowledgementPublisher

java.lang.Object

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

public class InboundAcknowledgementPublisher
extends Object

Constructor Summary

Constructors

Constructor	Description
InboundAcknowledgementPublisher(UUID aiidaId, tools.jackson.databind.ObjectMapper objectMapper, String acknowledgementTopic)
InboundAcknowledgementPublisher(UUID aiidaId, tools.jackson.databind.ObjectMapper objectMapper, String acknowledgementTopic, AckFormatterStrategyRegistry ackFormatterStrategyRegistry)

Method Summary

Modifier and Type	Method	Description
void	publishAcknowledgement(InboundRecord inboundRecord)
void	setMqttClient(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

InboundAcknowledgementPublisher

public InboundAcknowledgementPublisher(UUID aiidaId,
 tools.jackson.databind.ObjectMapper objectMapper,
 @Nullable
 String acknowledgementTopic)

InboundAcknowledgementPublisher

public InboundAcknowledgementPublisher(UUID aiidaId,
 tools.jackson.databind.ObjectMapper objectMapper,
 @Nullable
 String acknowledgementTopic,
 AckFormatterStrategyRegistry ackFormatterStrategyRegistry)

Method Details

setMqttClient

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

publishAcknowledgement

public void publishAcknowledgement(InboundRecord inboundRecord)