View Javadoc

1   /*
2    * Jour - java profiler and monitoring library
3    *
4    * Copyright (C) 2004 Jour team
5    *
6    * This library is free software; you can redistribute it and/or
7    * modify it under the terms of the GNU Library General Public
8    * License as published by the Free Software Foundation; either
9    * version 2 of the License, or (at your option) any later version.
10   *
11   * This library is distributed in the hope that it will be useful,
12   * but WITHOUT ANY WARRANTY; without even the implied warranty of
13   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14   * Library General Public License for more details.
15   *
16   * You should have received a copy of the GNU Library General Public
17   * License along with this library; if not, write to the
18   * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
19   * Boston, MA  02111-1307, USA.
20   */
21  package net.sf.jour.rt.agent;
22  
23  import org.apache.log4j.Logger;
24  
25  import net.sf.jour.util.queue.Queue;
26  import net.sf.jour.rt.RtProperties;
27  
28  /***
29   * TODO Add docs
30   *
31   * Created on 06.12.2004
32   * Contributing Author(s):
33   *
34   *   Misha Lifschitz <mishalifschitz at users.sourceforge.net> (Inital implementation)
35   *   Vlad Skarzhevskyy <vlads at users.sourceforge.net> (Inital implementation)
36   *
37   * @author vlads
38   * @version $Revision: 1.2 $ ($Author: vlads $)  $Date: 2004/12/15 08:00:36 $
39   */
40  public class BulkEventLog4jWriter implements BulkEventLogger {
41      
42      protected static final Logger log = Logger.getLogger(BulkEventLog4jWriter.class);
43      
44      private static Logger dst = null;
45      
46      private Logger getLogger(Thread key, Queue eventQueue) {
47          if (dst == null) {
48              dst = Logger.getLogger(RtProperties.getInstance().getProperty("BulkEventLog4jWriter.logger", "JourEventQueueLogger"));
49          }
50          return dst;
51      }
52      
53      public void recive(Thread key, Queue eventQueue) {
54          // TODO move to common code.
55          eventQueue.enqueueFirst(new JVMInfoEvent());
56          eventQueue.enqueueFirst(SystemInfoEvent.instance());
57          eventQueue.enqueueFirst(ThreadNumber.getThreadNumberEvent(key));
58          getLogger(key, eventQueue).info(eventQueue);
59      }
60      
61      public void close() {
62          if (dst != null) {
63             ;//TODO
64          }
65      }
66      
67      public void close(Thread key) {
68          
69      }
70  	
71      public boolean isClose() {
72  	    return false;
73  	}
74  
75  }