I was in the need to redirect the RMI logging output to log4j and created a
small adapter that handles that, which is an OutputStream that transact to
the Log4J loggers upon reception of new line character, flush or close.
Usage;
StreamAdapter sa = new StreamAdapter( logger , level );
RemoteServer.setLog( sa );
This is released as BeerWare;
"This license grant you to use the software in any way you want, no
limitations, provided;
a) You hold the author unresponsible for any and all effects.
b) Drink a beer to salute the author.
"
;o)
package com.ewarna.lz;
import java.io.OutputStream;
import org.apache.log4j.Logger;
import org.apache.log4j.Level;
import org.apache.log4j.Priority;
/** Adapter for Streams to be directed to log4j Loggers.
*
* <p>This project is using this to redirect the
* RMI Exception trace to Logger outputs, instead of the
* System.out/System.err (whichever it may be). However,
* this adapter is versatile enough to make any kind
* of OutputStream content to go to the Logger system.</p>
*
**/
public class StreamAdapter extends OutputStream
{
private static final char NEWLINE;
private Logger m_Logger;
private Priority m_Priority;
private StringBuffer m_Message;
static
{
NEWLINE = System.getProperty( "line.separator" ).charAt(0);
}
/** Creates the default StreamAdapter.
*<p>Convinience constructor for
* <code>StreamAdapter( Logger.getLogger( StreamAdapter.class ),
* Level.INFO );</code>
**/
public StreamAdapter()
{
this( Logger.getLogger( StreamAdapter.class ), Level.ERROR );
}
/** Creates a StreamAdapter connecting to the given logger.
*<p>Convinience constructor for
* <code>StreamAdapter( logger,
* Level.INFO );</code>
**/
public StreamAdapter( Logger logger )
{
this( logger, Level.INFO );
}
/** Creates a StreamAdapter connecting to a particular
* logger with a message of a particular priority/level.
*/
public StreamAdapter( Logger logger, Priority priority )
{
m_Logger = logger;
m_Priority = priority;
m_Message = new StringBuffer(200);
}
public void write( int b )
{
if( m_Logger != null && b == NEWLINE )
flush();
else
m_Message.append( (char) b );
}
/** Flushes the outputstream and sends the buffered bytes
* to its destination.
* <p> This causes the call to the <code>Logger.log</code>
* method, and will hence constitute a transaction in that
* system. This method is called whenever a new line character
* is encountered in the write stream, and upon close.
**/
public void flush()
{
if( m_Message.length() > 0 )
{
m_Logger.log( m_Priority, m_Message.toString() );
m_Message.setLength(0);
}
}
public void close()
{
flush();
}
public Logger getLogger()
{
return m_Logger;
}
public void setLogger( Logger logger )
{
m_Logger = logger;
}
public void setPriority( Priority priority )
{
m_Priority = priority;
}
public Priority getPriority()
{
return m_Priority;
}
}
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
