Begin gemaakt met devices die events kunnen sturen naar applications via main opdat actions worden uitgevoerd.

java/src/pm/Main.java

@@ -1,27 +1,45 @@
 package pm;
 
 import java.util.ArrayList;
+import java.util.Queue;
+import java.util.concurrent.ConcurrentLinkedQueue;
 
+import pm.applicatie.voorbeeld.Voorbeeld;
+import pm.application.Application;
 import pm.device.Device;
-import pm.device.Features;
+import pm.device.example.Example;
-import pm.device.exampledevice.ExampleDevice;
+import pm.event.Event;
 
 public class Main {
+    ArrayList<Application> applicationList;
     ArrayList<Device> deviceList;
+    Queue<Event> eventQueue;
 
     public Main() {
+        applicationList = new ArrayList<Application>();
         deviceList = new ArrayList<Device>();
+        eventQueue = new ConcurrentLinkedQueue<Event>();
+    }
+
+    public void addApplication(Application application) {
+        applicationList.add(application);
+    }
+
+    public boolean removeApplication(Application application) {
+        return applicationList.remove(application);
     }
 
     public void addDevice(Device device) {
         deviceList.add(device);
-        if (device.hasFeature(Features.RESTART)) {
-            device.start();
     }
+
+    public boolean removeDevie(Device device) {
+        return deviceList.remove(device);
     }
 
     public void start() {
-       addDevice(new ExampleDevice());
+        addDevice(new Example(eventQueue));
+        addApplication(new Voorbeeld());
     }
 
     public static void main(String[] args) {

java/src/pm/action/Action.java

@@ -0,0 +1,5 @@
+package pm.action;
+
+public enum Action {
+    START
+}

java/src/pm/applicatie/voorbeeld/Voorbeeld.java

@@ -0,0 +1,9 @@
+package pm.applicatie.voorbeeld;
+
+import pm.application.Application;
+
+public class Voorbeeld extends Application {
+    protected void start() {
+        System.out.println("jeheee!");
+    }
+}

java/src/pm/application/Application.java

@@ -0,0 +1,15 @@
+package pm.application;
+
+import pm.action.Action;
+
+public abstract class Application {
+    public void invoke(Action action) {
+        switch (action) {
+            case START:
+                start();
+                break;
+        }
+    }
+
+    protected abstract void start();
+}

java/src/pm/device/Device.java

@@ -1,31 +1,18 @@
 package pm.device;
 
 import java.util.ArrayList;
+import java.util.Queue;
 
-import pm.device.feature.Feature;
+import pm.event.Event;
 
 
 public abstract class Device {
-    protected ArrayList<Feature> featureList;
+    protected Queue<Event> eventQueue;
 
-    protected Device() {
+    protected Device(Queue<Event> eventQueue) {
-        featureList = new ArrayList<Feature>();
+        this.eventQueue = eventQueue;
+        initialise();
     }
 
-    public void addFeature(Feature feature) {
+    public void initialise() {}
-        if (!hasFeature(feature)) {
-            if (this instanceof feature.getClass()) {
-                
-            }
-            featureList.add(feature);
-        }
-    }
-
-    public void removeFeature(Feature feature) {
-        featureList.remove(feature);
-    }
-
-    public boolean hasFeature(Feature feature) {
-        return featureList.contains(feature);
-    }
 }

java/src/pm/device/Features.java

@@ -1,11 +0,0 @@
-package pm.device;
-
-import pm.device.feature.Feature;
-import pm.device.feature.Restart;
-
-public enum Features {
-    Restart ((Class<Restart>)Restart.class);
-
-    Features(Class<Feature> feature) {
-    }
-}

java/src/pm/device/example/Example.java

@@ -0,0 +1,18 @@
+package pm.device.example;
+
+import java.util.Queue;
+
+import pm.action.Action;
+import pm.device.Device;
+import pm.event.Event;
+
+public class Example extends Device {
+    public Example(Queue<Event> eventQueue) {
+        super(eventQueue);
+    }
+
+    public void initialise() {
+        Event event = new Event(Action.START);
+        eventQueue.add(event);
+    }
+}

java/src/pm/device/exampledevice/ExampleDevice.java

@@ -1,22 +0,0 @@
-package pm.device.exampledevice;
-
-import pm.device.Device;
-import pm.device.Features;
-
-public class ExampleDevice extends Device {
-    public ExampleDevice() {
-        addFeature(Features.Restart);
-    }
-
-    public void start() {
-                
-    }
-
-    public void stop() {
-                
-    }
-
-    public void restart() {
-                
-    }
-}

java/src/pm/device/feature/Feature.java

@@ -1,5 +0,0 @@
-package pm.device.feature;
-
-public interface Feature {
-    public void apply();             
-}

java/src/pm/device/feature/Restart.java

@@ -1,8 +0,0 @@
-package pm.device.feature;
-
-public interface Restart extends Feature {
-    public static final String feature = "RESTART";
-
-    public void stop();
-    public void restart();
-}

java/src/pm/event/Event.java

@@ -1,16 +1,11 @@
 package pm.event;
 
-import pm.device.feature.Feature;
+import pm.action.Action;
 
 public class Event {
-    public Feature feature;
+    protected Action action;
     
-    public Event(Feature feature) {
+    public Event(Action action) {
-        this.feature = feature;
+        this.action = action;
     }
-    
-    public void Apply() {
-           feature.apply();
-    }
-    
 }