Naamgeving van spreaders aangepast naar router. Vernieuwing door onbenul!

java/src/pm/Application.java

@@ -22,10 +22,12 @@ public abstract class Application extends EventHandler implements Activatable {
 
     public void activate() {
         start();
+        active = true;
     }
 
     public void deactivate() {
         stop();
+        active = false;
     }
 
     public void exit() {

java/src/pm/Client.java

@@ -1,6 +1,6 @@
 package pm;
 
-import pm.event.spreader.NetworkSpreader;
+import pm.event.router.GlobalRouter;
 import pm.exception.event.spreader.NetworkSpreaderException;
 
 public class Client extends Manager {
@@ -10,7 +10,7 @@ public class Client extends Manager {
     public static final int PORT = 6789;
 
     public Client(String ip, int port) throws NetworkSpreaderException {
-        super(new NetworkSpreader(ip, port));
+        super(new GlobalRouter(ip, port));
     }
 
     public Client() throws NetworkSpreaderException {

java/src/pm/Device.java

@@ -18,7 +18,7 @@ public abstract class Device extends EventHandler implements Activatable {
     protected SequenceListener sequenceListener;
 
     static {
-        SequenceListener.initialise(eventSpreader);
+        SequenceListener.initialise(eventRouter);
     }
 
     public Device(String title) {
@@ -89,10 +89,12 @@ public abstract class Device extends EventHandler implements Activatable {
     
     public void activate() {
         start();
+        active = true;
     }
 
     public void deactivate() {
         stop();
+        active = false;
     }
 
     public void exit() {

java/src/pm/Main.java

@@ -10,7 +10,7 @@ import pm.application.cmd.windows.wmp.WMPApplication;
 import pm.application.itunes.iTunesApplication;
 import pm.application.mpc.MPCApplication;
 import pm.application.vlc.VLCApplication;
-import pm.event.spreader.LocalSpreader;
+import pm.event.router.LocalRouter;
 import pm.util.ArrayCycle;
 import pm.value.Action;
 
@@ -20,18 +20,18 @@ public class Main extends Manager {
     protected ApplicationSelector applicationSelector;
 
     public Main() {
-        super(new LocalSpreader());
+        super(new LocalRouter());
     }
 
     protected void action(Action action) {
         log.debug(String.format("action(%s)", action));
         switch (action) {
             case NEXT:
-                eventSpreader.set(applicationCycle.next());
+                eventRouter.set(applicationCycle.next());
                 System.out.println(applicationCycle.current());
                 break;
             case PREVIOUS:
-                eventSpreader.set(applicationCycle.previous());
+                eventRouter.set(applicationCycle.previous());
                 System.out.println(applicationCycle.current());
                 break;
             case EXIT:
@@ -51,7 +51,7 @@ public class Main extends Manager {
             new WinampApplication()};        
         applicationSelector = new ApplicationSelector(applicationArray);
         applicationCycle = new ArrayCycle<Application>(applicationArray);
-        eventSpreader.set(applicationCycle.current());
+        eventRouter.set(applicationCycle.current());
         super.start(false);
     }
 

java/src/pm/Manager.java

@@ -14,7 +14,7 @@ import pm.device.panel.PanelDevice;
 import pm.device.player.PlayerDevice;
 import pm.device.wiimote.WiimoteDevice;
 import pm.event.EventHandler;
-import pm.event.EventSpreader;
+import pm.event.EventRouter;
 
 public abstract class Manager extends EventHandler {
     protected Log log = LogFactory.getLog(getClass());
@@ -22,9 +22,9 @@ public abstract class Manager extends EventHandler {
 
     protected ArrayList<Device> deviceList;
 
-    public Manager(EventSpreader eventSpreader) {
+    public Manager(EventRouter eventRouter) {
-        EventHandler.initialise(eventSpreader);
+        EventHandler.initialise(eventRouter);
-        eventSpreader.start();
+        eventRouter.start();
     }
 
     public void start() {

java/src/pm/application/itunes/iTunesApplication.java

@@ -92,13 +92,13 @@ public class iTunesApplication extends Application implements iTunesEventsInterf
     public void onPlayerPlayEvent(ITTrack iTrack) {
         if (active) {
             System.out.println("iTunes play");
-            eventSpreader.add(new Feedback());
+            eventRouter.add(new Feedback());
         }
     }
     public void onPlayerStopEvent(ITTrack iTrack) {
         if (active) {
             System.out.println("iTunes stop");
-            eventSpreader.add(new Feedback());
+            eventRouter.add(new Feedback());
         }
     }
     public void onPlayerPlayingTrackChangedEvent(ITTrack iTrack) {}

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

@@ -100,7 +100,7 @@ public class NetworkDevice extends Device {
                     object = objectInputStream.readObject();
                     if (object instanceof Event) {
                         log.debug("event binnen!");
-                        eventSpreader.add((Event) object);
+                        eventRouter.add((Event) object);
                     }
                     log.debug("iets te lezen!");                    
                 } while (object != null);

java/src/pm/event/EventHandler.java

@@ -5,14 +5,14 @@ import pm.event.task.Continuous;
 import pm.value.Action;
 
 public abstract class EventHandler extends EventListener {
-    protected static EventSpreader eventSpreader;
+    protected static EventRouter eventRouter;
 
-    public static void initialise(EventSpreader eventSpreader) {
+    public static void initialise(EventRouter eventRouter) {
-        EventHandler.eventSpreader = eventSpreader;
+        EventHandler.eventRouter = eventRouter;
     }
 
     protected void initialise() {
-        eventSpreader.add(this);
+        eventRouter.add(this);
     }
 
     public void event(Event event) {

java/src/pm/event/EventListener.java

@@ -15,10 +15,6 @@ public abstract class EventListener extends Worker {
     }
 
     public void add(Event event) {
-        System.out.println("Eventlistener krijgt event via add()");
-        System.out.println(this);
-        System.out.println(event);
-        System.out.println(">>>");
         eventQueue.add(event);
         synchronized (available) {
             available.notifyAll();

java/src/pm/event/EventRouter.java

@@ -4,7 +4,7 @@ import java.util.ArrayList;
 
 import pm.Application;
 
-public abstract class EventSpreader extends EventListener {
+public abstract class EventRouter extends EventListener {
     protected ArrayList<EventListener> eventListenerList;
     protected Application application;
 
@@ -12,7 +12,7 @@ public abstract class EventSpreader extends EventListener {
         this.application = application;
     }
 
-    public EventSpreader() {
+    public EventRouter() {
         eventListenerList = new ArrayList<EventListener>();
     }
 

java/src/pm/event/router/GlobalRouter.java

@@ -1,4 +1,4 @@
-package pm.event.spreader;
+package pm.event.router;
 
 import java.io.IOException;
 import java.io.ObjectInputStream;
@@ -7,16 +7,16 @@ import java.net.Socket;
 import java.net.UnknownHostException;
 import pm.Event;
 import pm.Worker;
-import pm.event.EventSpreader;
+import pm.event.EventRouter;
 import pm.event.Feedback;
 import pm.exception.event.spreader.NetworkSpreaderException;
 
-public class NetworkSpreader extends EventSpreader {
+public class GlobalRouter extends EventRouter {
     protected Socket socket;
     protected ObjectOutputStream objectOutputStream;
     protected ObjectInputStream objectInputStream;
 
-    public NetworkSpreader(String ip, int port) throws NetworkSpreaderException {
+    public GlobalRouter(String ip, int port) throws NetworkSpreaderException {
         try {
             socket = new Socket(ip, port);
             objectOutputStream = new ObjectOutputStream(socket.getOutputStream());

java/src/pm/event/router/LocalRouter.java

@@ -1,11 +1,11 @@
-package pm.event.spreader;
+package pm.event.router;
 
 import pm.Event;
 import pm.event.EventListener;
-import pm.event.EventSpreader;
+import pm.event.EventRouter;
 import pm.value.Target;
 
-public class LocalSpreader extends EventSpreader {
+public class LocalRouter extends EventRouter {
     public void event(Event event) {
         System.out.println("LocalSpreader krijgt event via evet()");
         System.out.println(application);