Skip to content
Snippets Groups Projects
Commit 4c3e15af authored by Luke O'mahony's avatar Luke O'mahony
Browse files

upd: updated sqs listener to accept one sensor data sample at a time and added...

upd: updated sqs listener to accept one sensor data sample at a time and added date field to data after parsing
parent c5ebbf4b
No related merge requests found
...@@ -12,6 +12,7 @@ import org.springframework.messaging.handler.annotation.MessageMapping; ...@@ -12,6 +12,7 @@ import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.IOException; import java.io.IOException;
import java.util.Date;
import java.util.List; import java.util.List;
@Component @Component
...@@ -32,8 +33,9 @@ public class SqsListenerEndpoint { ...@@ -32,8 +33,9 @@ public class SqsListenerEndpoint {
//Using jackson object mapper to parse json //Using jackson object mapper to parse json
ObjectMapper sensorDataMapper = new ObjectMapper(); 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
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment