Changeset 63

Timestamp:

06/26/13 11:31:52 (11 years ago)

Author:

stoda

Message:

Logger modified

Location:

trunk/src

Files:

• main/java/omq/client/proxy/MultiProxymq.java (added)
• main/java/omq/server/InvocationThread.java (modified) (1 diff)
• test/java/omq/test/calculator/CalculatorImpl.java (modified) (3 diffs)
• test/java/omq/test/serializer (added)
• test/java/omq/test/serializer/CalculatorTest.java (added)

trunk/src/main/java/omq/server/InvocationThread.java

@@ -47 +47 @@
                                 String requestID = request.getId();
 
-                                logger.debug("Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID);
+                                logger.debug("Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID + ", serializerType: " + serializerType);
 
                                 // Invoke the method

trunk/src/test/java/omq/test/calculator/CalculatorImpl.java

@@ -3 +3 @@
 import java.io.IOException;
 
+import omq.common.broker.Broker;
 import omq.exception.SerializerException;
 import omq.server.RemoteObject;
@@ -8 +9 @@
 public class CalculatorImpl extends RemoteObject implements Calculator {
         private int mult = 0;
+        private Broker broker;
 
         public CalculatorImpl() throws Exception {
                 super();
+        }
+
+        public CalculatorImpl(Broker broker) throws Exception {
+                super();
+                this.broker = broker;
         }
 
@@ -35 +42 @@
         @Override
         public void asyncDivideByZero() throws IOException, SerializerException {
-                // ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
-                // Broker.trigger(ze);
+                ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
+                broker.trigger(ze);
                 // notifyEvent(ze);
         }