vbatts/microservices-demo
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Update TamagotchiService.java

Browse source
This commit is contained in:
Steinwagner 2019-12-11 11:35:41 +01:00
parent 3d2faac24a
commit c123ff8ac0
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/tamagotchi-service/src/main/java/com/sap/tamagotchi/service/TamagotchiService.java
View file

@ -84,8 +84,8 @@ public class TamagotchiService {
.parallelStream() .parallelStream()
.filter(device -> !device.isAlive()) .filter(device -> !device.isAlive())
.forEach(device -> { .forEach(device -> {
deviceRegistry.remove(device.getId());
sendTamagotchiDefunctNotifiction(device.getId()); sendTamagotchiDefunctNotifiction(device.getId());
deviceRegistry.remove(device.getId());
LOGGER.info("{} has died", device.getId()); LOGGER.info("{} has died", device.getId());
}); });
} }
@ -93,6 +93,9 @@ public class TamagotchiService {
private void sendTamagotchiDefunctNotifiction(String id) { private void sendTamagotchiDefunctNotifiction(String id) {
Device device = deviceRegistry.get(id); Device device = deviceRegistry.get(id);
if (device == null) {
return;
}
String defunctMessage = String.format("Tamagotchi %s of %s passed away", device.getOwner(), device.getOwner()); String defunctMessage = String.format("Tamagotchi %s of %s passed away", device.getOwner(), device.getOwner());
DefunctNotification defunctNotification = new DefunctNotification(defunctMessage); DefunctNotification defunctNotification = new DefunctNotification(defunctMessage);
try { try {