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
-
Field Summary
Fields inherited from class energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor
logger, objectMapper -
Constructor Summary
ConstructorsConstructorDescriptionStatusMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository, tools.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink) -
Method Summary
Modifier and TypeMethodDescriptionvoidprocessMessage(org.eclipse.paho.mqttv5.common.MqttMessage message) Methods inherited from class energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor
getAndValidatePermissionRequest
-
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
-