public class CriticalTemperatureObserver implements SimpleObserverI { SteamEngineC myEngine; int criticalTemperature; public CriticalTemperatureObserver(SteamEngineC engine, int critical) { myEngine = engine; criticalTemperature = critical; myEngine.add(this); } @Override public void update() { if (myEngine.getTemp() > criticalTemperature) { System.out.println("Critcal temperature reached, shutting down..."); System.exit(0); } } }