Changeset 17 for trunk


Ignore:
Timestamp:
05/22/13 18:41:56 (11 years ago)
Author:
stoda
Message:

JavaImp? error with Events solved

Location:
trunk/objectmq/src/omq
Files:
1 added
6 edited

Legend:

Unmodified
Added
Removed
  • trunk/objectmq/src/omq/common/event/EventWrapper.java

    r16 r17  
    11package omq.common.event;
    22
    3 public class EventWrapper {
     3import java.io.Serializable;
     4
     5public class EventWrapper implements Serializable {
     6
     7        /**
     8         *
     9         */
     10        private static final long serialVersionUID = 1L;
     11
    412        private String type;
    513        private Event event;
     
    816        }
    917
    10         //TODO change to simpleName
     18        // TODO change to simpleName
    1119        public EventWrapper(Event event) {
    1220                this.event = event;
  • trunk/objectmq/src/omq/common/util/Serializers/JavaImp.java

    r14 r17  
    77
    88import omq.common.event.Event;
     9import omq.common.event.EventWrapper;
    910import omq.common.message.Request;
    1011import omq.common.message.Response;
     
    5455        @Override
    5556        public Event deserializeEvent(byte[] bytes) throws SerializerException {
    56                 return (Event) deserliazeObject(bytes);
     57                EventWrapper wrapper = (EventWrapper) deserliazeObject(bytes);
     58                return wrapper.getEvent();
    5759        }
    5860
  • trunk/objectmq/src/omq/ztest/calculator/Calculator.java

    r16 r17  
    1616        @AsyncMethod
    1717        public void mult(int x, int y);
    18        
     18
     19        @AsyncMethod
     20        public void sendMessage(Message m);
     21
    1922        @AsyncMethod
    2023        public void divideByZero() throws IOException, SerializerException;
  • trunk/objectmq/src/omq/ztest/calculator/CalculatorImpl.java

    r16 r17  
    33import java.io.IOException;
    44
     5import omq.client.annotation.AsyncMethod;
    56import omq.exception.SerializerException;
    67import omq.server.remote.request.RemoteObject;
     
    3637        }
    3738
     39        @Override
     40        @AsyncMethod
     41        public void sendMessage(Message m) {
     42                System.out.println("Code = "+m.getCode());
     43                System.out.println("Message = "+m.getMessage());
     44        }
     45       
     46       
     47
    3848}
  • trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java

    r16 r17  
    2424                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    2525                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    26 //              env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.KryoImp");
     26                // env.setProperty(ParameterQueue.SERIALIZERNAME,
     27                // "omq.common.util.Serializers.KryoImp");
    2728                env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.GsonImp");
    2829                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     
    8283                Thread.sleep(200);
    8384        }
     85
     86        @Test
     87        public void sendMessage() throws Exception {
     88                Message m = new Message(2334, "Hello objectmq");
     89                remoteCalc.sendMessage(m);
     90        }
    8491}
  • trunk/objectmq/src/omq/ztest/calculator/ServerTest.java

    r16 r17  
    3232                Broker.bind("calculator1", calc);
    3333                Broker.bind("calculator2", calc2);
     34
     35                System.out.println("Server started");
    3436        }
    3537}
Note: See TracChangeset for help on using the changeset viewer.