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 3290a841eb6598765b01a287ab5c413effa4dd25..8569e62312ee21c7338df96f26f49acc3d14e749 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