source: branches/objectmq-1.0/src/omq/ztest/calculator/CalculatorImpl.java

package omq.ztest.calculator;

import java.io.IOException;

import omq.client.annotation.AsyncMethod;
import omq.common.broker.Broker;
import omq.exception.SerializerException;
import omq.server.remote.request.RemoteObject;

public class CalculatorImpl extends RemoteObject implements Calculator {
        private int mult = 0;

        public CalculatorImpl() throws Exception {
                super();
        }

        private static final long serialVersionUID = 1L;

        public int add(int x, int y) {
                return x + y;
        }

        public void mult(int x, int y) {
                mult = x * y;
        }

        public int getMult() {
                return mult;
        }

        public void setMult(int mult) {
                this.mult = mult;
        }

        public void divideByZero() throws IOException, SerializerException {
                ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
                Broker.trigger(ze);
                //notifyEvent(ze);
        }

        @Override
        @AsyncMethod
        public void sendMessage(Message m) {
                System.out.println("Code = "+m.getCode());
                System.out.println("Message = "+m.getMessage());
        }
        
        

}