Package energy.eddie.regionconnector.aiida.mqtt.message.processor.status

Class StatusMessageProcessor

java.lang.Object

energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor

energy.eddie.regionconnector.aiida.mqtt.message.processor.status.StatusMessageProcessor

All Implemented Interfaces:

AiidaMessageProcessor

@Component
public class StatusMessageProcessor
extends BaseMessageProcessor

Field Summary

Fields inherited from class energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor

logger, objectMapper

Constructor Summary

Constructors

Constructor	Description
StatusMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository, tools.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink)

Method Summary

Modifier and Type	Method	Description
String	forTopicPath()
void	processMessage(org.eclipse.paho.mqttv5.common.MqttMessage message)

Methods inherited from class energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor

getAndValidatePermissionRequest

Methods inherited from class java.lang.Object

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

Constructor Details

StatusMessageProcessor

public StatusMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository,
 tools.jackson.databind.ObjectMapper objectMapper,
 reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink)

Method Details

processMessage

public void processMessage(org.eclipse.paho.mqttv5.common.MqttMessage message)

forTopicPath

public String forTopicPath()