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

Timestamp:

09/27/13 17:50:41 (11 years ago)

Author:

stoda

Message:

Semaphores added and removed, ack error discovered and solutioned... Some tests added

Supervisor interface created and more things I'll do later...

TODO: supervisor!!

File:

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

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

@@ -38 +38 @@
         private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
 
-        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;
+        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 static final Map<String, Class<?>> primitiveClasses = new HashMap<String, Class<?>>();
@@ -317 +317 @@
                  */
 
+                boolean autoAck = false;
+
                 // Declare a new consumer
                 consumer = new QueueingConsumer(channel);
-                channel.basicConsume(queue, true, consumer);
-                channel.basicConsume(multiQueue, true, consumer);
+                channel.basicConsume(queue, autoAck, consumer);
+                channel.basicConsume(multiQueue, autoAck, consumer);
         }