Changeset 83 for trunk/src/main/java/omq/server

Timestamp:

07/08/13 13:29:24 (11 years ago)

Author:

stoda

Message:

J

Location:

trunk/src/main/java/omq/server

Files:

• InvocationThread.java (modified) (1 diff)
• RemoteObject.java (modified) (8 diffs)
• RemoteWrapper.java (modified) (2 diffs)

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

@@ -16 +16 @@
 
 /**
+ * An invocationThread waits for requests an invokes them.
  * 
  * @author Sergi Toda <sergi.toda@estudiants.urv.cat>

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

@@ -23 +23 @@
 
 /**
+ * A RemoteObject when it's started will be waiting for requests and will invoke
+ * them. When a RemoteObject is started it listens two queues, the first one has
+ * the same name as its reference and the second one is its multiqueue -this
+ * name can be set using a property, be aware to use a name not used by another
+ * object!!!-.
  * 
  * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
@@ -58 +63 @@
         }
 
+        /**
+         * This method starts a remoteObject.
+         * 
+         * @param reference
+         *            - broker's binding referece
+         * @param broker
+         *            - broker that binds this remoteObject
+         * @param env
+         *            - properties of this remoteObject
+         * @throws Exception
+         */
         public void startRemoteObject(String reference, Broker broker, Properties env) throws Exception {
                 this.broker = broker;
@@ -81 +97 @@
                 // Start this listener
                 this.start();
-        }
-
-        public void startTriggerEvent(String reference, Broker broker) throws Exception {
-                this.broker = broker;
-                UID = reference;
-                if (channel == null || !channel.isOpen()) {
-                        channel = broker.getChannel();
-                }
         }
 
@@ -133 +141 @@
         }
 
+        /**
+         * This method kills all the threads waiting for requests
+         * 
+         * @throws IOException
+         *             - If an operation failed.
+         */
         public void kill() throws IOException {
                 logger.warn("Killing objectmq: " + this.getRef());
@@ -141 +155 @@
         }
 
+        /**
+         * This method invokes the method specified by methodName and arguments
+         * 
+         * @param methodName
+         * @param arguments
+         * @return result
+         * @throws Exception
+         */
         public Object invokeMethod(String methodName, Object[] arguments) throws Exception {
 
@@ -149 +171 @@
         }
 
+        /**
+         * This method loads the method specified by methodName and args
+         * 
+         * @param methodName
+         * @param args
+         * @return method
+         * @throws NoSuchMethodException
+         *             - If the method cannot be found
+         */
         private Method loadMethod(String methodName, Object[] args) throws NoSuchMethodException {
                 Method m = null;
@@ -171 +202 @@
         }
 
+        /**
+         * This method loads a method which uses primitives as arguments
+         * 
+         * @param methodName
+         *            - name of the method wanted to invoke
+         * @param argArray
+         *            - arguments
+         * @return method
+         * @throws NoSuchMethodException
+         *             - If the method cannot be found
+         */
         private Method loadMethodWithPrimitives(String methodName, Class<?>[] argArray) throws NoSuchMethodException {
                 if (argArray != null) {
@@ -213 +255 @@
         }
 
+        /**
+         * This method starts the queues using the information got in the
+         * environment.
+         * 
+         * @throws Exception
+         */
         private void startQueues() throws Exception {
                 // Get info about which exchange and queue will use

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

@@ -13 +13 @@
 
 /**
+ * This class is used to encapsulate the invocationThreads under the
+ * RemoteObject.
  * 
  * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
@@ -40 +42 @@
         }
 
+        /**
+         * This method notifies a delivery to an invocationThread using a
+         * blockingQueue.
+         * 
+         * @param delivery
+         *            - delivery which contains a Request to be invoked
+         * @throws Exception
+         */
         public void notifyDelivery(Delivery delivery) throws Exception {
                 this.deliveryQueue.put(delivery);
         }
 
+        /**
+         * This method interrups all the invocationThreads under this remoteWrapper
+         */
         public void stopRemoteWrapper() {
                 logger.warn("Stopping Invocation threads vinculed to " + obj.getRef());