Changeset 83 for trunk/src/main/java/omq/client
- Timestamp:
- 07/08/13 13:29:24 (11 years ago)
- Location:
- trunk/src/main/java/omq/client
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/main/java/omq/client/annotation/MultiMethod.java
r82 r83 6 6 import java.lang.annotation.Target; 7 7 8 /** 9 * Annotation which indicates a method as Multi. 10 * 11 * @author Sergi Toda <sergi.toda@estudiants.urv.cat> 12 * 13 */ 8 14 @Retention(RetentionPolicy.RUNTIME) 9 15 @Target(ElementType.METHOD) -
trunk/src/main/java/omq/client/proxy/MultiProxymq.java
r78 r83 15 15 16 16 /** 17 * TODO Aquesta classe s'eliminarà tant bon punt es faci un proxymq més18 * intel·ligent17 * MultiProxy class. Every proxy created with this class will invoke 18 * multi-asynchronous methods. 19 19 * 20 * @author sergi20 * @author Sergi Toda <sergi.toda@estudiants.urv.cat> 21 21 * 22 22 */ -
trunk/src/main/java/omq/client/proxy/Proxymq.java
r82 r83 278 278 } 279 279 280 /** 281 * This method returns an array with length @MultiMethod.waitNum() with all 282 * the responses received. 283 * 284 * @param corrId 285 * - Correlation Id of the request 286 * @param wait 287 * - Array length 288 * @param timeout 289 * - Timeout read in @SyncMethod.timeout(). If the timeout is set 290 * in 2 seconds, the system will wait 2 seconds for the arriving 291 * of all the responses. 292 * @param type 293 * - Must be an Array type 294 * @return resultArray 295 * @throws Exception 296 */ 280 297 private Object getResults(String corrId, int wait, long timeout, Class<?> type) throws Exception { 281 298 Response resp = null; 299 // Get the component type of an array 282 300 Class<?> actualType = type.getComponentType(); 283 301
Note: See TracChangeset
for help on using the changeset viewer.