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-10 16:44:50 +01:00
parent b1583185a5
commit cd930c6b99
1 changed files with 2 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -10,7 +10,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.sap.tamagotchi.model.Device; import com.sap.tamagotchi.model.Device;
import com.sap.tamagotchi.model.IoTMessage;
import com.sap.tamagotchi.publisher.PublisherService; import com.sap.tamagotchi.publisher.PublisherService;
@Service @Service
@ -37,18 +36,12 @@ public class TamagotchiService {
return deviceRegistry.keySet(); return deviceRegistry.keySet();
} }
public void createDevice(Device device) { public Device createDevice(Device device) {
deviceRegistry.put(device.getDeviceId(), device); deviceRegistry.put(device.getDeviceId(), device);
return device;
} }
private void processDeviceEvents() { private void processDeviceEvents() {
deviceRegistry
.values()
.parallelStream()
.filter(d -> d.hasMessages())
.forEach(d -> {
Collection<IoTMessage> messages = d.getMessages();
});
} }
} }