Changeset 63 for trunk/src/test/java/omq

Timestamp:

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

Author:

stoda

Message:

Logger modified

Location:

trunk/src/test/java/omq/test

Files:

• calculator/CalculatorImpl.java (modified) (3 diffs)
• serializer (added)
• serializer/CalculatorTest.java (added)

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);
         }