Package energy.eddie.regionconnector.aiida.mqtt

Class MqttMessageCallback

java.lang.Object

energy.eddie.regionconnector.aiida.mqtt.MqttMessageCallback

All Implemented Interfaces:

org.eclipse.paho.mqttv5.client.MqttCallback

public class MqttMessageCallback
extends Object
implements org.eclipse.paho.mqttv5.client.MqttCallback

Constructor Summary

Constructors

Constructor	Description
MqttMessageCallback(AiidaPermissionRequestViewRepository permissionRequestViewRepository, reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink, reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataSink, reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
void	authPacketArrived(int reasonCode, org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)
void	connectComplete(boolean reconnect, String serverURI)
void	deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)
void	disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)
void	messageArrived(String topic, org.eclipse.paho.mqttv5.common.MqttMessage message)
void	mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)

Methods inherited from class java.lang.Object

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

Constructor Details

MqttMessageCallback

public MqttMessageCallback(AiidaPermissionRequestViewRepository permissionRequestViewRepository,
 reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink,
 reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataSink,
 reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

disconnected

public void disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)

Specified by:

disconnected in interface org.eclipse.paho.mqttv5.client.MqttCallback

mqttErrorOccurred

public void mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)

Specified by:

mqttErrorOccurred in interface org.eclipse.paho.mqttv5.client.MqttCallback

messageArrived

public void messageArrived(String topic,
 org.eclipse.paho.mqttv5.common.MqttMessage message)
                    throws com.fasterxml.jackson.core.JsonProcessingException,
PermissionNotFoundException,
PermissionInvalidException,
MqttTopicException

Specified by:

messageArrived in interface org.eclipse.paho.mqttv5.client.MqttCallback

Throws:

com.fasterxml.jackson.core.JsonProcessingException

PermissionNotFoundException

PermissionInvalidException

MqttTopicException

deliveryComplete

public void deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)

Specified by:

deliveryComplete in interface org.eclipse.paho.mqttv5.client.MqttCallback

connectComplete

public void connectComplete(boolean reconnect,
 String serverURI)

Specified by:

connectComplete in interface org.eclipse.paho.mqttv5.client.MqttCallback

authPacketArrived

public void authPacketArrived(int reasonCode,
 org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)

Specified by:

authPacketArrived in interface org.eclipse.paho.mqttv5.client.MqttCallback