Changeset 23 for trunk


Ignore:
Timestamp:
05/24/13 12:50:00 (11 years ago)
Author:
stoda
Message:
 
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/objectmq/src/omq/server/remote/request/InvocationThread.java

    r19 r23  
    3838                                Log.saveLog("Server-Deserialize", delivery.getBody());
    3939
    40                                 System.out.println("Invoke method: " + request.getMethod() + " CorrID: " + request.getId());
     40                                String methodName = request.getMethod();
     41                                String requestID = request.getId();
    4142
    42                                 // Invoke the method
    43                                 Object result = obj.invokeMethod(request.getMethod(), request.getArguments());
     43                                System.out.println("Invoke method: " + methodName + " CorrID: " + requestID);
     44
     45                                // Changed ---------------------------------------
     46                                Object result = null;
     47                                if ("commit".equalsIgnoreCase(methodName)) {
     48                                        Object[] arguments = request.getArguments();
     49                                        arguments[1] = ((String) arguments[1]) + "@@" + requestID;
     50                                        result = obj.invokeMethod(methodName, arguments);
     51                                } else {
     52                                        result = obj.invokeMethod(request.getMethod(), request.getArguments());
     53                                }
     54                                // -----------------------------------------------
     55
     56                                // // Invoke the method
     57                                // Object result = obj.invokeMethod(request.getMethod(),
     58                                // request.getArguments());
    4459
    4560                                if (!request.isAsync()) {
Note: See TracChangeset for help on using the changeset viewer.