Changeset 66

Timestamp:

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

Author:

stoda

Message:

startEventTrigger added

Location:

trunk/src

Files:

• main/java/omq/client/proxy/MultiProxymq.java (deleted)
• main/java/omq/common/broker/Broker.java (modified) (1 diff)
• main/java/omq/server/RemoteObject.java (modified) (1 diff)
• test/java/omq/test/event (added)
• test/java/omq/test/event/EventTrigger.java (added)
• test/java/omq/test/event/EventTriggerImpl.java (added)
• test/java/omq/test/event/ZeroEvent.java (added)
• test/java/omq/test/event/ZeroListener.java (added)

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() {