Package energy.eddie.regionconnector.aiida.mqtt.message.processor.data.agnostic

Class OpaqueEnvelopeMessageProcessor

java.lang.Object

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

energy.eddie.regionconnector.aiida.mqtt.message.processor.data.agnostic.OpaqueEnvelopeMessageProcessor

All Implemented Interfaces:

AiidaMessageProcessor

@Component
public class OpaqueEnvelopeMessageProcessor
extends BaseMessageProcessor

Field Summary

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

logger, objectMapper

Constructor Summary

Constructors

Constructor	Description
OpaqueEnvelopeMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository, tools.jackson.databind.ObjectMapper objectMapper, reactor.core.publisher.Sinks.Many<OpaqueEnvelope> opaqueEnvelopeSink)

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

OpaqueEnvelopeMessageProcessor

public OpaqueEnvelopeMessageProcessor(AiidaPermissionRequestViewRepository permissionRequestViewRepository,
 tools.jackson.databind.ObjectMapper objectMapper,
 reactor.core.publisher.Sinks.Many<OpaqueEnvelope> opaqueEnvelopeSink)

Method Details

processMessage

public void processMessage(org.eclipse.paho.mqttv5.common.MqttMessage message)
                    throws PermissionNotFoundException,
PermissionInvalidException

Throws:

PermissionNotFoundException

PermissionInvalidException

forTopicPath

public String forTopicPath()