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

log4j added

File:
1 edited

Legend:

Unmodified
Added
Removed
  • 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
Note: See TracChangeset for help on using the changeset viewer.