net.sf.jour.rt.agent
Class BulkEventFileWriter

java.lang.Object
  extended bynet.sf.jour.rt.agent.BulkEventFileWriter
All Implemented Interfaces:
BulkEventLogger

public class BulkEventFileWriter
extends java.lang.Object
implements BulkEventLogger

This creates new file for each theread. Should be used by One thread only. Created on 02.12.2004 Contributing Author(s): Misha Lifschitz (Inital implementation) Vlad Skarzhevskyy (Inital implementation)

Version:
$Revision: 1.8 $ ($Author: vlads $) $Date: 2004/12/15 08:00:35 $
Author:
vlads

Field Summary
static long DEFAULT_EVENTS_MAX
           
protected  org.apache.log4j.Logger log
           
(package private) static java.lang.String runID
           
(package private)  SystemInfoEvent systemInfo
           
(package private)  ThreadNumber thread
           
static java.lang.String WRK_SUFIX
           
 
Constructor Summary
BulkEventFileWriter()
           
 
Method Summary
 void close()
          Close All and be ready to exit.
 void close(java.lang.Thread key)
          Close the Queue for this thread.
 boolean isClose()
           
 void recive(java.lang.Thread key, Queue eventQueue)
           
 void write(Queue eventQueue, ThreadNumber thread, SystemInfoEvent systemInfo)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

protected final org.apache.log4j.Logger log

runID

static java.lang.String runID

DEFAULT_EVENTS_MAX

public static final long DEFAULT_EVENTS_MAX
See Also:
Constant Field Values

WRK_SUFIX

public static final java.lang.String WRK_SUFIX
See Also:
Constant Field Values

thread

ThreadNumber thread

systemInfo

SystemInfoEvent systemInfo
Constructor Detail

BulkEventFileWriter

public BulkEventFileWriter()
Method Detail

recive

public void recive(java.lang.Thread key,
                   Queue eventQueue)
Specified by:
recive in interface BulkEventLogger

write

public void write(Queue eventQueue,
                  ThreadNumber thread,
                  SystemInfoEvent systemInfo)

close

public void close(java.lang.Thread key)
Close the Queue for this thread.

Specified by:
close in interface BulkEventLogger

isClose

public boolean isClose()
Specified by:
isClose in interface BulkEventLogger

close

public void close()
Description copied from interface: BulkEventLogger
Close All and be ready to exit.

Specified by:
close in interface BulkEventLogger


Copyright © 2004 sourceforge. All Rights Reserved.