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

refactor Notification

Browse source
This commit is contained in:
Steinwagner 2019-12-11 11:31:09 +01:00
parent 2a35e91cdd
commit dfc219cfde
2 changed files with 27 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

23
src/tamagotchi-service/src/main/java/com/sap/tamagotchi/model/DefunctNotification.java Normal file
View file

@ -0,0 +1,23 @@
package com.sap.tamagotchi.model;
import com.fasterxml.jackson.annotation.JsonProperty;
public class DefunctNotification implements IoTMessage {
@JsonProperty("message")
private final String message;
public DefunctNotification(String message) {
this.message = message;
}
@Override
public String getTopic() {
return "tamagotchi-defunct";
}
public String getMessage() {
return message;
}
}

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

@ -14,10 +14,9 @@ import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.sap.tamagotchi.model.Care;
import com.sap.tamagotchi.model.DefunctNotification;
import com.sap.tamagotchi.model.Device;
import com.sap.tamagotchi.model.IoTMessage;
import com.sap.tamagotchi.publisher.PublisherService;
@Service
@ -94,25 +93,10 @@ public class TamagotchiService {
private void sendTamagotchiDefunctNotifiction(String id) {
Device device = deviceRegistry.get(id);
IoTMessage m = new IoTMessage() {
@JsonProperty("message")
private String message = String.format("Tamagotchi %s of %s passed away", device.getOwner(), device.getOwner());
@Override
public String getTopic() {
return "tamagotchi-defunct";
}
public String getMessage() {
return message;
}
};
String defunctMessage = String.format("Tamagotchi %s of %s passed away", device.getOwner(), device.getOwner());
DefunctNotification defunctNotification = new DefunctNotification(defunctMessage);
try {
publisherService.publish(m);
publisherService.publish(defunctNotification);
LOGGER.info("defunct notification sent for {}", device.getId());
} catch (Exception ex) {
LOGGER.error("sendTamagotchiDefunctNotifiction failed: {}", ex.getMessage());