Changeset 19

Timestamp:

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

Author:

stoda

Message:

Sysos added to control what's happening

Location:

trunk/objectmq/src/omq

Files:

• client/proxy/Proxymq.java (modified) (3 diffs)
• client/remote/response/ResponseListener.java (modified) (1 diff)
• common/event/EventDispatcher.java (modified) (1 diff)
• common/util/ParameterQueue.java (modified) (1 diff)
• common/util/Serializer.java (modified) (2 diffs)
• server/remote/request/InvocationThread.java (modified) (3 diffs)
• ztest/calculator/ClientTest.java (moved) (moved from trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java) (1 diff)

trunk/objectmq/src/omq/client/proxy/Proxymq.java

@@ -121 +121 @@
                 // Publish the request
                 if (request.isAsync()) {
+                        System.out.println("Publish async request ->" + request.getId());
                         publishAsyncRequest(request);
                         return null;
                 } else {
+                        System.out.println("Publish sync request ->" + request.getId());
                         return publishSyncRequest(request, method.getReturnType());
                 }
         }
-        
-        private void publishMessage(Request request, String replyQueueName) throws IOException, SerializerException{
+
+        private void publishMessage(Request request, String replyQueueName) throws IOException, SerializerException {
                 String corrId = request.getId();
 
@@ -139 +141 @@
 
                 // Publish the message
-                byte[] bytesRequest = Serializer.serialize(request);                            
+                byte[] bytesRequest = Serializer.serialize(request);
                 channel.basicPublish(exchange, routingkey, props, bytesRequest);
-                Log.saveLog("Client-Serialize", bytesRequest);          
+                Log.saveLog("Client-Serialize", bytesRequest);
         }
 
@@ -167 +169 @@
                         } catch (TimeoutException te) {
                                 System.out.println("Timeout exception catched " + te);
+                                te.printStackTrace();
                         }
                         i++;
                 }
                 throw new RetryException(retries, timeout);
-
         }
 

trunk/objectmq/src/omq/client/remote/response/ResponseListener.java

@@ -60 +60 @@
                                 // Get the response with its uid
                                 uid_request = delivery.getProperties().getCorrelationId();
+                                System.out.println("Response reveived -> " + uid_request);
 
                                 // Stores the new response

trunk/objectmq/src/omq/common/event/EventDispatcher.java

@@ -95 +95 @@
                                 event = Serializer.deserializeEvent(delivery.getBody());
 
+                                System.out.println("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
+
                                 // Dispatch it
                                 dispatch(event.getTopic(), event);
                         } catch (InterruptedException i) {
                                 System.out.println("InterruptedException e: " + i);
+                                i.printStackTrace();
                         } catch (ShutdownSignalException e) {
                                 System.out.println("ShutdownSignalException e: " + e);
+                                e.printStackTrace();
                         } catch (ConsumerCancelledException e) {
                                 System.out.println("ConsumerCancelledException e: " + e);
+                                e.printStackTrace();
                         } catch (Exception e) {
                                 System.out.println("Exception e: " + e);
+                                e.printStackTrace();
                         }
                 }

trunk/objectmq/src/omq/common/util/ParameterQueue.java

@@ -47 +47 @@
          * Time in milis
          */
-        public static long DEFAULT_TIMEOUT = 5 * 1000 * 60;
+        public static long DEFAULT_TIMEOUT = 1 * 1000 * 60;
 
 }

trunk/objectmq/src/omq/common/util/Serializer.java

@@ -26 +26 @@
                         enableCompression = Boolean.valueOf(env.getProperty(ParameterQueue.ENABLECOMPRESSION, "false"));
                 } catch (EnvironmentException e) {
+                        e.printStackTrace();
                 }
 
@@ -40 +41 @@
                                         throw new ClassNotFoundException("Class name is null or empty.");
                                 }
-                                
+
                                 serializer = (ISerializer) Class.forName(className).newInstance();
                         } catch (Exception ex) {

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) {

trunk/objectmq/src/omq/ztest/calculator/ClientTest.java

@@ -11 +11 @@
 import org.junit.Test;
 
-public class CalculatorTest {
+public class ClientTest {
         private static Calculator remoteCalc;
         private static Calculator remoteCalc2;