Changeset 47 for trunk/src/main/java/omq/client/proxy

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/client/proxy/Proxymq.java (modified) (4 diffs)

trunk/src/main/java/omq/client/proxy/Proxymq.java

@@ -47 +47 @@
 
         private String uid;
+        private transient String serializerType;
         private transient ResponseListener rListener;
         private transient EventDispatcher dispatcher;
@@ -89 +90 @@
                 // this.channel = Broker.getChannel();
                 this.env = env;
+
+                // set the serializer type
+                serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
 
                 listeners = new HashMap<String, EventListener<?>>();
@@ -150 +154 @@
 
                 // Add the correlation ID and create a replyTo property
-                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).build();
+                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType).build();
 
                 // Publish the message
-                byte[] bytesRequest = Serializer.serialize(request);
+                byte[] bytesRequest = Serializer.serialize(serializerType, request);
                 // TODO See this
                 // channel.basicPublish(exchange, routingkey, props, bytesRequest);
@@ -306 +310 @@
         }
 
+        public static void stopProxy() {
+                proxies = new HashMap<String, Object>();
+        }
+
+        public static Map<String, Object> getProxies() {
+                return proxies;
+        }
+
+        public static void setProxies(Map<String, Object> proxies) {
+                Proxymq.proxies = proxies;
+        }
+
         @Override
         public String getRef() {