Changeset 53 for trunk/src/main/java/omq/server/RemoteObject.java

Timestamp:

06/20/13 16:57:39 (11 years ago)

Author:

stoda

Message:

Non static broker
TODO: change all test to see whether the new broker configuration works

File:

• trunk/src/main/java/omq/server/RemoteObject.java (modified) (5 diffs)

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

@@ -39 +39 @@
         private String UID;
         private Properties env;
+        private transient Broker broker;
+        private transient Serializer serializer;
         private transient RemoteWrapper remoteWrapper;
         private transient Map<String, List<Class<?>>> params;
@@ -60 +62 @@
         }
 
-        public void startRemoteObject(String reference, Properties env) throws Exception {
-                this.UID = reference;
-                this.env = env;
+        public void startRemoteObject(String reference, Broker broker) throws Exception {
+                this.broker = broker;
+                UID = reference;
+                env = broker.getEnvironment();
+                serializer = broker.getSerializer();
 
                 params = new HashMap<String, List<Class<?>>>();
@@ -75 +79 @@
                 // Get num threads to use
                 int numThreads = Integer.parseInt(env.getProperty(ParameterQueue.NUM_THREADS, "1"));
-                remoteWrapper = new RemoteWrapper(this, numThreads);
+                remoteWrapper = new RemoteWrapper(this, numThreads, broker.getSerializer());
 
                 startQueues();
@@ -130 +134 @@
                 EventWrapper wrapper = new EventWrapper(event);
                 channel.exchangeDeclare(UID, "fanout");
-                channel.basicPublish(UID, "", null, Serializer.serialize(wrapper));
+                channel.basicPublish(UID, "", null, serializer.serialize(wrapper));
         }
 
@@ -221 +225 @@
 
                 // Start channel
-                channel = Broker.getNewChannel();
+                channel = broker.getNewChannel();
 
                 // Declares and bindings