From 4c3e15af7854d3f57fc036d2e7e6070e02ba3026 Mon Sep 17 00:00:00 2001
From: Luke <lomah001@gold.ac.uk>
Date: Sun, 14 Apr 2019 16:02:35 +0100
Subject: [PATCH] upd: updated sqs listener to accept one sensor data sample at
a time and added date field to data after parsing
---
.../com/backend/glowhouse/AWS/sqs/SqsListenerEndpoint.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/backend/glowhouse/AWS/sqs/SqsListenerEndpoint.java b/src/main/java/com/backend/glowhouse/AWS/sqs/SqsListenerEndpoint.java
index 3290a84..8569e62 100644
--- a/src/main/java/com/backend/glowhouse/AWS/sqs/SqsListenerEndpoint.java
+++ b/src/main/java/com/backend/glowhouse/AWS/sqs/SqsListenerEndpoint.java
@@ -12,6 +12,7 @@ import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.stereotype.Component;
import java.io.IOException;
+import java.util.Date;
import java.util.List;
@Component
@@ -32,8 +33,9 @@ public class SqsListenerEndpoint {
//Using jackson object mapper to parse json
ObjectMapper sensorDataMapper = new ObjectMapper();
- List<SensorData> sensorDataList = sensorDataMapper.readValue(message, new TypeReference<List<SensorData>>(){});
+ SensorData data = sensorDataMapper.readValue(message, new TypeReference<SensorData>(){});
+ data.setDate(new Date());
- this.sensorDataService.processMultipleSensorData(sensorDataList);
+ this.sensorDataService.processSensorData(data);
}
}
\ No newline at end of file
--
GitLab