diff --git a/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/repo/TemperatureReadingRepository.java b/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/repo/TemperatureReadingRepository.java index 7aabd9f4..70335e1e 100644 --- a/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/repo/TemperatureReadingRepository.java +++ b/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/repo/TemperatureReadingRepository.java @@ -26,8 +26,8 @@ import example.app.temp.model.TemperatureReading; // tag::class[] public interface TemperatureReadingRepository extends CrudRepository { - List findByTimestampGreaterThanAndTimestampLessThan(Long timestampLowerBound, - Long timestampUpperBound); + List findByTimestampGreaterThanAndTimestampLessThan( + Long timestampLowerBound, Long timestampUpperBound); @Query("SELECT count(*) FROM /TemperatureReadings WHERE temperature >= 212") Integer countBoilingTemperatureReadings(); diff --git a/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/service/TemperatureSensor.java b/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/service/TemperatureSensor.java index 95702521..70a2c3e8 100644 --- a/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/service/TemperatureSensor.java +++ b/spring-geode-samples/boot/actuator/src/main/java/example/app/temp/service/TemperatureSensor.java @@ -31,8 +31,10 @@ import example.app.temp.repo.TemperatureReadingRepository; @SuppressWarnings("unused") public class TemperatureSensor { - private final PrimitiveIterator.OfInt temperatureStream = new Random(System.currentTimeMillis()) - .ints(-100, 400).iterator(); + private final PrimitiveIterator.OfInt temperatureStream = + new Random(System.currentTimeMillis()) + .ints(-100, 400) + .iterator(); private final TemperatureReadingRepository repository; @@ -45,7 +47,11 @@ public class TemperatureSensor { @Scheduled(fixedRateString = "${example.app.temp.sensor.reading.schedule.rate:1000}") public void readTemperature() { - this.repository.save(log(TemperatureReading.newTemperatureReading(temperatureStream.nextInt()))); + + TemperatureReading temperatureReading = + TemperatureReading.newTemperatureReading(temperatureStream.nextInt()); + + this.repository.save(log(temperatureReading)); } private TemperatureReading log(TemperatureReading temperatureReading) {