Changeset 92 for branches/supervisor/src/main/java/omq/supervisor

Timestamp:

10/01/13 12:02:41 (11 years ago)

Author:

stoda

Message:

TODO: delete in supervisor
check the code

Location:

branches/supervisor/src/main/java/omq/supervisor

Files:

• ISupervisor.java (deleted)
• MultiBroker.java (deleted)
• OmqSettings.java (modified) (1 diff)
• Supervisor.java (modified) (1 diff)
• SupervisorImpl.java (added)
• SupervisorThread.java (added)

branches/supervisor/src/main/java/omq/supervisor/OmqSettings.java

@@ -1 +1 @@
 package omq.supervisor;
 
+import java.io.Serializable;
 import java.util.Properties;
 
-public class OmqSettings {
+public class OmqSettings implements Serializable {
+        
+        
 
+        /**
+         * 
+         */
+        private static final long serialVersionUID = 1L;
         private String reference;
         private String className;

branches/supervisor/src/main/java/omq/supervisor/Supervisor.java

@@ -1 +1 @@
 package omq.supervisor;
 
-import java.util.Map;
-import java.util.Set;
+import omq.Remote;
 
-import omq.common.broker.RemoteBroker;
+public interface Supervisor extends Remote {
 
-public class Supervisor {
+        public void subscribe(String brokerName) throws Exception;
 
-        private Set<String> bindReferences;
-        private Map<String, RemoteBroker> brokers;
+        public void spawnObject(OmqSettings settings) throws Exception;
 
-        private void checkObject() {
-                String reference = null;
-
-                int numObjects = 0;
-
-                if(minObjects > numObjects || maxMessages < numEncuats){
-                        spawn:
-                                pregunta a tots i qui no té l'objecte li poses
-                }else if(numEncuats < minMessages && minObjects > numObjects){
-                        delete:
-                                pregunta a tots i qui té l'objecte li treus
-                }
-        }
 }