Changeset 66 for trunk/src/main/java/omq

Timestamp:

06/26/13 16:14:45 (11 years ago)

Author:

stoda

Message:

startEventTrigger added

Location:

trunk/src/main/java/omq

Files:

• client/proxy/MultiProxymq.java (deleted)
• common/broker/Broker.java (modified) (1 diff)
• server/RemoteObject.java (modified) (1 diff)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -150 +150 @@
                 try {
                         remote.startRemoteObject(reference, this);
+                        remoteObjs.put(reference, remote);
+                } catch (Exception e) {
+                        throw new RemoteException(e);
+                }
+        }
+        
+        public void startTriggerEvent(String reference, RemoteObject remote) throws RemoteException {
+                try {
+                        remote.startTriggerEvent(reference, this);
                         remoteObjs.put(reference, remote);
                 } catch (Exception e) {

trunk/src/main/java/omq/server/RemoteObject.java

@@ -90 +90 @@
         }
 
+        public void startTriggerEvent(String reference, Broker broker) throws Exception {
+                this.broker = broker;
+                UID = reference;
+                if (channel == null || !channel.isOpen()) {
+                        channel = broker.getChannel();
+                }
+        }
+
         @Override
         public void run() {