In NetworkSpreader Feedback opvangen.

java/src/pm/device/network/NetworkDevice.java

@@ -3,7 +3,6 @@ package pm.device.network;
 import java.io.IOException;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
-import java.io.OutputStream;
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.util.ArrayList;
@@ -15,7 +14,6 @@ import pm.Event;
 import pm.Worker;
 import pm.event.Feedback;
 import pm.exception.device.DeviceInitialiseException;
-import pm.value.Action;
 
 public class NetworkDevice extends Device {
     public static final int PORT = 6789;

java/src/pm/event/spreader/NetworkSpreader.java

@@ -1,21 +1,43 @@
 package pm.event.spreader;
 
 import java.io.IOException;
+import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
 import java.net.Socket;
 import java.net.UnknownHostException;
 import pm.Event;
+import pm.Worker;
 import pm.event.EventSpreader;
+import pm.event.Feedback;
 import pm.exception.event.spreader.NetworkSpreaderException;
 
 public class NetworkSpreader extends EventSpreader {
     protected Socket socket;
     protected ObjectOutputStream objectOutputStream;
+    protected ObjectInputStream objectInputStream;
 
     public NetworkSpreader(String ip, int port) throws NetworkSpreaderException {
         try {
             socket = new Socket(ip, port);
             objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
+            objectInputStream = new ObjectInputStream(socket.getInputStream());
+            new Worker() {
+                public void run() {
+                    try {
+                        Object object;
+                        do {
+                            object = objectInputStream.readObject();
+                            if (object instanceof Feedback) {
+                                add((Feedback) object);
+                            }                 
+                        } while (object != null);
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    } catch (ClassNotFoundException e) {
+                        e.printStackTrace();
+                    }
+                }
+            };
             return;
         } catch (UnknownHostException e) {
         } catch (IOException e) {}