Changeset 47 for trunk/src/main/java/omq/server/InvocationThread.java

Timestamp:

06/18/13 16:51:22 (11 years ago)

Author:

stoda

Message:

Refactoring Environment class - deleted.
StopBroker? problems solved (?)
Server can receive send and receive messages in different formats.
Some tests modified

TODO: finish all the tests, add log4j

File:

• trunk/src/main/java/omq/server/InvocationThread.java (modified) (2 diffs)

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

@@ -35 +35 @@
                                 Delivery delivery = deliveryQueue.take();
 
+                                String serializerType = delivery.getProperties().getType();
+
                                 // Deserialize the json
-                                Request request = Serializer.deserializeRequest(delivery.getBody(), obj);
+                                Request request = Serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
                                 // Log.saveLog("Server-Deserialize", delivery.getBody());
 
@@ -66 +68 @@
                                         BasicProperties replyProps = new BasicProperties.Builder().appId(obj.getRef()).correlationId(props.getCorrelationId()).build();
 
-                                        byte[] bytesResponse = Serializer.serialize(resp);
+                                        byte[] bytesResponse = Serializer.serialize(serializerType, resp);
                                         channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);