Changeset 92 for branches/supervisor/src/main/java/omq/server/RemoteObject.java

Timestamp:

10/01/13 12:02:41 (11 years ago)

Author:

stoda

Message:

TODO: delete in supervisor
check the code

File:

• branches/supervisor/src/main/java/omq/server/RemoteObject.java (modified) (3 diffs)

branches/supervisor/src/main/java/omq/server/RemoteObject.java

@@ -38 +38 @@
         private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
 
-        protected String UID;
-        protected Properties env;
-        protected transient Broker broker;
-        protected transient String multiQueue;
-        protected transient RemoteWrapper remoteWrapper;
-        protected transient Map<String, List<Class<?>>> params;
-        protected transient Channel channel;
-        protected transient QueueingConsumer consumer;
-        protected transient boolean killed = false;
+        private String UID;
+        private Properties env;
+        private transient Broker broker;
+        private transient String multiQueue;
+        private transient RemoteWrapper remoteWrapper;
+        private transient Map<String, List<Class<?>>> params;
+        private transient Channel channel;
+        private transient QueueingConsumer consumer;
+        private transient boolean killed = false;
 
         private static final Map<String, Class<?>> primitiveClasses = new HashMap<String, Class<?>>();
@@ -254 +254 @@
         }
 
+        public Broker getBroker() {
+                return broker;
+        }
+
         /**
          * This method starts the queues using the information got in the
@@ -319 +323 @@
                 boolean autoAck = false;
 
+                //TODO see if this is useless
+                int prefetchCount = 1;
+                channel.basicQos(prefetchCount);
+
                 // Declare a new consumer
                 consumer = new QueueingConsumer(channel);