Changeset 49 for trunk/src/main/java/omq/server/RemoteWrapper.java

Timestamp:

06/19/13 15:59:53 (11 years ago)

Author:

stoda

Message:

log4j added

File:

• trunk/src/main/java/omq/server/RemoteWrapper.java (modified) (4 diffs)

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

@@ -4 +4 @@
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingDeque;
+
+import org.apache.log4j.Logger;
 
 import com.rabbitmq.client.QueueingConsumer;
@@ -14 +16 @@
  */
 public class RemoteWrapper {
+        private static final Logger logger = Logger.getLogger(RemoteWrapper.class.getName());
+
         private RemoteObject obj;
         private int numThreads;
@@ -25 +29 @@
                 deliveryQueue = new LinkedBlockingDeque<QueueingConsumer.Delivery>();
 
-                System.out.println("RemoteWrapper -> Object: " + obj.getRef() + ", numthreads listening = " + numThreads);
+                logger.info("Object reference: " + obj.getRef() + ", numthreads listening = " + numThreads);
 
                 for (int i = 0; i < numThreads; i++) {
@@ -39 +43 @@
 
         public void stopRemoteWrapper() {
+                logger.warn("Stopping Invocation threads vinculed to " + obj.getRef());
                 for (InvocationThread thread : invocationList) {
                         thread.interrupt();