User: oberg
Date: 00/06/16 06:10:30
Modified: src/main/org/jboss/logging FileLogging.java Logger.java
Log:
Added configuration service
Changed interceptors to be messagebased
Added mini webserver
Changed server bootstrap process
Revision Changes Path
1.2 +3 -3 jboss/src/main/org/jboss/logging/FileLogging.java
Index: FileLogging.java
===================================================================
RCS file: /products/cvs/ejboss/jboss/src/main/org/jboss/logging/FileLogging.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- FileLogging.java 2000/04/22 14:30:13 1.1
+++ FileLogging.java 2000/06/16 13:10:30 1.2
@@ -18,7 +18,7 @@
*
* @see <related>
* @author Rickard �berg ([EMAIL PROTECTED])
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class FileLogging
implements FileLoggingMBean, MBeanRegistration, NotificationListener
@@ -102,9 +102,9 @@
{
try
{
- server.addNotificationListener(new
ObjectName(server.getDefaultDomain(),"service","Log"),this,null,null);
-
out = new PrintStream(new FileOutputStream(new File(new
File(getClass().getResource("/log.properties").getFile()).getParent(), logName)));
+
+ server.addNotificationListener(new
ObjectName(server.getDefaultDomain(),"service","Log"),this,null,null);
log.log("Logging started");
return new ObjectName(OBJECT_NAME);
1.3 +28 -4 jboss/src/main/org/jboss/logging/Logger.java
Index: Logger.java
===================================================================
RCS file: /products/cvs/ejboss/jboss/src/main/org/jboss/logging/Logger.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- Logger.java 2000/05/30 18:32:28 1.2
+++ Logger.java 2000/06/16 13:10:30 1.3
@@ -17,17 +17,19 @@
*
* @see <related>
* @author Rickard �berg ([EMAIL PROTECTED])
- * @version $Revision: 1.2 $
+ * @version $Revision: 1.3 $
*/
public class Logger
extends NotificationBroadcasterSupport
- implements LoggerMBean, MBeanRegistration, NotificationBroadcaster
+ implements LoggerMBean, MBeanRegistration, NotificationBroadcaster, Runnable
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
long sequence = 0;
Date now = new Date();
+
+ boolean running = true;
ArrayList notificationListeners = new ArrayList();
@@ -76,12 +78,15 @@
public Logger()
{
logger = this;
+
+ Thread runner = new Thread(this, "Log time updater");
+ runner.setDaemon(true);
+ runner.start();
}
// Public --------------------------------------------------------
public synchronized void fireNotification(String type, Object source, String
message)
{
- now.setTime(System.currentTimeMillis());
Notification n = new Notification(type, this, sequence++, now, message);
n.setUserData(source);
@@ -103,7 +108,26 @@
throws java.lang.Exception
{}
- public void postDeregister() {}
+ public void postDeregister()
+ {
+ running = false;
+ }
+ // Runnable implementation ---------------------------------------
+ public void run()
+ {
+ while (running)
+ {
+ now.setTime(System.currentTimeMillis());
+
+ try
+ {
+ Thread.sleep(5*1000);
+ } catch (InterruptedException e)
+ {
+ // Ignore
+ }
+ }
+ }
}