Changeset 19 for trunk/objectmq/src/omq/server/remote/request/InvocationThread.java

Timestamp:

05/23/13 15:34:55 (11 years ago)

Author:

stoda

Message:

Sysos added to control what's happening

File:

• trunk/objectmq/src/omq/server/remote/request/InvocationThread.java (modified) (3 diffs)

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());
+
                                 // Invoke the method
                                 Object result = obj.invokeMethod(request.getMethod(), request.getArguments());
@@ -48 +50 @@
                                         BasicProperties props = delivery.getProperties();
 
-                                        BasicProperties replyProps = new BasicProperties.Builder().appId(obj.getRef())
-                                                        .correlationId(props.getCorrelationId()).build();
+                                        BasicProperties replyProps = new BasicProperties.Builder().appId(obj.getRef()).correlationId(props.getCorrelationId()).build();
 
                                         byte[] bytesResponse = Serializer.serialize(resp);
@@ -58 +59 @@
 
                         } catch (InterruptedException i) {
+                                i.printStackTrace();
                                 killed = true;
                         } catch (Exception e) {