Changeset 23 for trunk

Timestamp:

05/24/13 12:50:00 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/objectmq/src/omq/server/remote/request/InvocationThread.java (modified) (1 diff)

trunk/objectmq/src/omq/server/remote/request/InvocationThread.java

@@ -38 +38 @@
                                 Log.saveLog("Server-Deserialize", delivery.getBody());
 
-                                System.out.println("Invoke method: " + request.getMethod() + " CorrID: " + request.getId());
+                                String methodName = request.getMethod();
+                                String requestID = request.getId();
 
-                                // Invoke the method
-                                Object result = obj.invokeMethod(request.getMethod(), request.getArguments());
+                                System.out.println("Invoke method: " + methodName + " CorrID: " + requestID);
+
+                                // Changed ---------------------------------------
+                                Object result = null;
+                                if ("commit".equalsIgnoreCase(methodName)) {
+                                        Object[] arguments = request.getArguments();
+                                        arguments[1] = ((String) arguments[1]) + "@@" + requestID;
+                                        result = obj.invokeMethod(methodName, arguments);
+                                } else {
+                                        result = obj.invokeMethod(request.getMethod(), request.getArguments());
+                                }
+                                // -----------------------------------------------
+
+                                // // Invoke the method
+                                // Object result = obj.invokeMethod(request.getMethod(),
+                                // request.getArguments());
 
                                 if (!request.isAsync()) {