Changeset 83 for trunk/src/main/java/omq/common/message/Request.java

Timestamp:

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

Author:

stoda

Message:

J

File:

• trunk/src/main/java/omq/common/message/Request.java (modified) (4 diffs)

trunk/src/main/java/omq/common/message/Request.java

@@ -3 +3 @@
 import java.io.Serializable;
 
+/**
+ * Serializable request information. This class is used to send the information
+ * to the server. It has information about which method is wanted to invoke, its
+ * parameters, its correlation id and if a response is needed -asynchronous
+ * method-.
+ * 
+ * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
+ * 
+ */
 public class Request implements Serializable {
 
@@ -20 +29 @@
         private transient int retries;
 
+        // This constructor is used by kryo
         public Request() {
         }
@@ -38 +48 @@
         }
 
+        /**
+         * This method creates a new synchronous request
+         * 
+         * @param id
+         *            - correlation id of this invocation
+         * @param method
+         *            - method name wanted to call
+         * @param params
+         *            - parameters of this method
+         * @return - new SyncRequest
+         */
         public static Request newSyncRequest(String id, String method, Object[] params) {
                 return new Request(id, method, false, params);
         }
 
+        /**
+         * This method creates a new synchronous request
+         * 
+         * @param id
+         *            - correlation id of this invocation
+         * @param method
+         *            - method name wanted to call
+         * @param params
+         *            - parameters of this method
+         * @param retries
+         *            - How many retries will be done
+         * @param timeout
+         *            - Timeout for every retry
+         * @param multi
+         *            - If the method is multi
+         * @param wait
+         *            - If the method is multi how many responses will be listened
+         * @return - new SyncRequest
+         */
         public static Request newSyncRequest(String id, String method, Object[] params, int retries, long timeout, boolean multi, int wait) {
                 Request req = new Request(id, method, false, params, multi);
@@ -50 +90 @@
         }
 
+        /**
+         * This method creates a new asynchronous request
+         * 
+         * @param id
+         *            - correlation id of this invocation
+         * @param method
+         *            - method name wanted to call
+         * @param params
+         *            - parameters of this method
+         * @param multi
+         *            - If the method is multi
+         * @return new AsyncRequest
+         */
         public static Request newAsyncRequest(String id, String method, Object[] params, boolean multi) {
                 return new Request(id, method, true, params, multi);