Changeset 55 for trunk/src/main/java/omq/common/message

Timestamp:

06/21/13 16:55:58 (11 years ago)

Author:

stoda

Message:

@MultiMethod? implemented and working with @AsyncMethod? annotation.
TODO: @Multi with SyncMethod?(waitNum = x) -> Must return a List<?>
Refactoring in Proxymq if it's necessary

File:

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

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

@@ -35 +35 @@
         }
 
-        public Request(String id2, String method2, boolean b, Object[] params2, boolean multi2) {
-                // TODO Auto-generated constructor stub
+        private Request(String id, String method, boolean async, Object[] params, boolean multi) {
+                this.id = id;
+                this.method = method;
+                this.async = async;
+                this.params = params;
+                this.multi = multi;
         }
 
@@ -43 +47 @@
         }
 
-        public static Request newSyncRequest(String id, String method, Object[] params, int retries, long timeout) {
-                Request req = new Request(id, method, false, params);
+        public static Request newSyncRequest(String id, String method, Object[] params, int retries, long timeout, boolean multi) {
+                Request req = new Request(id, method, false, params, multi);
                 req.setRetries(retries);
                 req.setTimeout(timeout);