Changeset 110 for branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.java

Timestamp:

10/22/13 15:15:51 (11 years ago)

Author:

stoda

Message:

Supervisor seems to work

File:

• branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.java (modified) (3 diffs)

branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.java

@@ -28 +28 @@
         @Override
         public void spawnObject(String reference, String className, Properties env) throws Exception {
+                System.out.println("SPAWN broker = " + this.getUID());
                 RemoteObject remote = (RemoteObject) Class.forName(className).newInstance();
                 getBroker().bind(reference, remote, env);
@@ -34 +35 @@
         @Override
         public void spawnObject(String reference, String className) throws Exception {
+                System.out.println("SPAWN broker = " + this.getUID());
                 RemoteObject remote = (RemoteObject) Class.forName(className).newInstance();
                 getBroker().bind(reference, remote);
@@ -50 +52 @@
         @Override
         public HasObject hasObjectInfo(String reference) throws RetryException {
-                System.out.println("Hola soc un broker"+ getRef() + ", "+getUID()+ ", fil: "+Thread.currentThread().getId());
+                System.out.println("Hola soc un broker" + getRef() + ", " + getUID() + ", fil: " + Thread.currentThread().getId());
                 if (getBroker().getRemoteObjs().containsKey(reference)) {
                         RemoteObject r = getBroker().getRemoteObjs().get(reference);