Ignore:
Timestamp:
06/19/13 15:59:53 (11 years ago)
Author:
stoda
Message:

log4j added

Location:
trunk/src/main/java/omq/server
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • trunk/src/main/java/omq/server/InvocationThread.java

    r47 r49  
    88import omq.common.util.Serializer;
    99import omq.exception.OmqException;
     10
     11import org.apache.log4j.Logger;
    1012
    1113import com.rabbitmq.client.AMQP.BasicProperties;
    … …  
    1921 */
    2022public class InvocationThread extends Thread {
     23        private static final Logger logger = Logger.getLogger(InvocationThread.class.getName());
    2124        private RemoteObject obj;
    2225        private BlockingQueue<Delivery> deliveryQueue;
    … …  
    4447                                String requestID = request.getId();
    4548
    46                                 System.out.println("Invoke method: " + methodName + " CorrID: " + requestID);
     49                                logger.debug("Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID);
    4750
    4851                                // Invoke the method
    … …  
    5356                                } catch (InvocationTargetException e) {
    5457                                        Throwable throwable = e.getTargetException();
     58                                        logger.error("Object: " + obj.getRef() + " at method: " + methodName + ", corrID" + requestID, throwable);
    5559                                        error = new OmqException(throwable.getClass().getCanonicalName(), throwable.getMessage());
    5660                                } catch (NoSuchMethodException e) {
     61                                        logger.error("Object: " + obj.getRef() + " cannot find method: " + methodName);
    5762                                        error = new OmqException(e.getClass().getCanonicalName(), e.getMessage());
    5863                                }
    … …  
    7580
    7681                        } catch (InterruptedException i) {
    77                                 i.printStackTrace();
     82                                logger.error(i);
    7883                                killed = true;
    7984                        } catch (Exception e) {
    80                                 System.out.println("Error a l'Invocation Thread \nException: " + e);
    81                                 e.printStackTrace();
     85                                logger.error("Object: " + obj.getRef(), e);
    8286                        }
    8387

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

    r44 r49  
    1010import java.util.Properties;
    1111
     12import org.apache.log4j.Logger;
     13
    1214import omq.Remote;
    1315import omq.common.broker.Broker;
    … …  
    3335
    3436        private static final long serialVersionUID = -1778953938739846450L;
     37        private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
    3538
    3639        private String UID;
    … …  
    8588                        try {
    8689                                Delivery delivery = consumer.nextDelivery();
    87                                 System.out.println("RemoteObject: " + UID + " has received a message");
     90
     91                                logger.debug(UID + " has received a message");
     92
    8893                                remoteWrapper.notifyDelivery(delivery);
    8994                        } catch (InterruptedException i) {
    90                                 i.printStackTrace();
     95                                logger.error(i);
    9196                        } catch (ShutdownSignalException e) {
    92                                 e.printStackTrace();
     97                                logger.error(e);
    9398                                try {
    9499                                        if (channel.isOpen()) {
    … …  
    101106                                                Thread.sleep(milis);
    102107                                        } catch (InterruptedException e2) {
    103                                                 e2.printStackTrace();
    104                                         }
    105                                         e1.printStackTrace();
     108                                                logger.error(e2);
     109                                        }
     110                                        logger.error(e1);
    106111                                }
    107112                        } catch (ConsumerCancelledException e) {
    108                                 e.printStackTrace();
     113                                logger.error(e);
    109114                        } catch (SerializerException e) {
    110                                 e.printStackTrace();
     115                                logger.error(e);
    111116                        } catch (Exception e) {
    112                                 e.printStackTrace();
     117                                logger.error(e);
    113118                        }
    114119                }
    … …  
    129134
    130135        public void kill() throws IOException {
     136                logger.warn("Killing objectmq: " + this.getRef());
    131137                killed = true;
    132138                interrupt();
    … …  
    218224
    219225                // Declares and bindings
    220                 System.out.println("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
     226                logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
    221227                channel.exchangeDeclare(exchange, "direct");
    222228                channel.queueDeclare(queue, durable, false, false, null);
    … …  
    224230
    225231                // Declare the event topic fanout
    226                 System.out.println("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
     232                logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + UID);
    227233                channel.exchangeDeclare(UID, "fanout");
    228234

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

    r44 r49  
    44import java.util.concurrent.BlockingQueue;
    55import java.util.concurrent.LinkedBlockingDeque;
     6
     7import org.apache.log4j.Logger;
    68
    79import com.rabbitmq.client.QueueingConsumer;
    … …  
    1416 */
    1517public class RemoteWrapper {
     18        private static final Logger logger = Logger.getLogger(RemoteWrapper.class.getName());
     19
    1620        private RemoteObject obj;
    1721        private int numThreads;
    … …  
    2529                deliveryQueue = new LinkedBlockingDeque<QueueingConsumer.Delivery>();
    2630
    27                 System.out.println("RemoteWrapper -> Object: " + obj.getRef() + ", numthreads listening = " + numThreads);
     31                logger.info("Object reference: " + obj.getRef() + ", numthreads listening = " + numThreads);
    2832
    2933                for (int i = 0; i < numThreads; i++) {
    … …  
    3943
    4044        public void stopRemoteWrapper() {
     45                logger.warn("Stopping Invocation threads vinculed to " + obj.getRef());
    4146                for (InvocationThread thread : invocationList) {
    4247                        thread.interrupt();
Note: See TracChangeset for help on using the changeset viewer.