Index: trunk/objectmq/src/omq/server/remote/request/InvocationThread.java
===================================================================
--- trunk/objectmq/src/omq/server/remote/request/InvocationThread.java	(revision 22)
+++ trunk/objectmq/src/omq/server/remote/request/InvocationThread.java	(revision 23)
@@ -38,8 +38,23 @@
 				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()) {