added startup handlers so we can see what's happening for all the mqtt

receivers

Author: atimgraves

IoTSonnenUploader/src/main/java/com/oracle/demo/timg/iot/iotsonnenuploader/mqtt/MqttCommandHandler.java

@@ -47,8 +47,10 @@ Software and the Larger Work(s), and to sublicense the foregoing rights on
 import com.oracle.demo.timg.iot.iotsonnenuploader.incommingdata.SonnenConfiguration;
 
 import io.micronaut.context.annotation.Requires;
+import io.micronaut.context.event.StartupEvent;
 import io.micronaut.mqtt.annotation.MqttSubscriber;
 import io.micronaut.mqtt.annotation.Topic;
+import io.micronaut.runtime.event.annotation.EventListener;
 import io.micronaut.scheduling.TaskExecutors;
 import io.micronaut.scheduling.annotation.ExecuteOn;
 import io.micronaut.serde.ObjectMapper;
@@ -96,4 +98,9 @@ public void receive(CommandReceived command) throws IOException {
 		CompletableFuture<Void> publishResp = responsePublisher.publishCommandResponse(resp);
 		publishResp.thenRun(() -> log.info("Sent command response " + resp));
 	}
+
+	@EventListener
+	public void onStartup(StartupEvent event) {
+		log.info("Started command handler");
+	}
 }

IoTSonnenUploader/src/main/java/com/oracle/demo/timg/iot/iotsonnenuploader/mqtt/MqttReferenceMonitor.java

@@ -39,8 +39,10 @@ Software and the Larger Work(s), and to sublicense the foregoing rights on
 import com.oracle.demo.timg.iot.iotsonnenuploader.devicesettings.DeviceSettings;
 
 import io.micronaut.context.annotation.Requires;
+import io.micronaut.context.event.StartupEvent;
 import io.micronaut.mqtt.annotation.MqttSubscriber;
 import io.micronaut.mqtt.annotation.Topic;
+import io.micronaut.runtime.event.annotation.EventListener;
 import lombok.extern.java.Log;
 
 @Log
@@ -71,4 +73,9 @@ public void seferenceMonitorStatus(String status) {
 	public void referenceMonitorCommandresponse(String commandresponse) {
 		log.info("Reference recieved commandresponse " + commandresponse);
 	}
+
+	@EventListener
+	public void onStartup(StartupEvent event) {
+		log.info("Started reference monitor");
+	}
 }

IoTSonnenUploader/src/main/java/com/oracle/demo/timg/iot/iotsonnenuploader/mqtt/MqttUploadMonitor.java

@@ -41,8 +41,10 @@ Software and the Larger Work(s), and to sublicense the foregoing rights on
 import com.oracle.demo.timg.iot.iotsonnenuploader.incommingdata.SonnenStatus;
 
 import io.micronaut.context.annotation.Requires;
+import io.micronaut.context.event.StartupEvent;
 import io.micronaut.mqtt.annotation.MqttSubscriber;
 import io.micronaut.mqtt.annotation.Topic;
+import io.micronaut.runtime.event.annotation.EventListener;
 import lombok.extern.java.Log;
 
 @Log
@@ -62,4 +64,9 @@ public void receiveConfig(SonnenConfiguration config) {
 	public void receiveStatus(SonnenStatus status) {
 		log.info("Monitor recieved status " + status);
 	}
+
+	@EventListener
+	public void onStartup(StartupEvent event) {
+		log.info("Started upload monitor");
+	}
 }