Class RawDataMessageProcessor
java.lang.Object
energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor
energy.eddie.regionconnector.aiida.mqtt.message.processor.data.raw.RawDataMessageProcessor
- All Implemented Interfaces:
AiidaMessageProcessor
-
Field Summary
Fields inherited from class energy.eddie.regionconnector.aiida.mqtt.message.processor.BaseMessageProcessor
logger, objectMapper -
Constructor Summary
ConstructorsConstructorDescriptionRawDataMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository, tools.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink) -
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
-
RawDataMessageProcessor
public RawDataMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository, tools.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink)
-
-
Method Details
-
processMessage
public void processMessage(org.eclipse.paho.mqttv5.common.MqttMessage message) throws PermissionNotFoundException, PermissionInvalidException -
forTopicPath
-