SocketNodepublic class SocketNode extends Object implements Runnable| Read {@link LoggingEvent} objects sent from a remote client using
Sockets (TCP). These logging events are logged according to local
policy, as if they were generated locally.
For example, the socket node might decide to log events to a
local file and also resent them to a second socket node. |
| Fields Summary |
|---|
| Socket | socket | | LoggerRepository | hierarchy | | ObjectInputStream | ois | | static Logger | logger |
| Constructors Summary |
|---|
public SocketNode(Socket socket, LoggerRepository hierarchy)
this.socket = socket;
this.hierarchy = hierarchy;
try {
ois = new ObjectInputStream(
new BufferedInputStream(socket.getInputStream()));
}
catch(Exception e) {
logger.error("Could not open ObjectInputStream to "+socket, e);
}
|
| Methods Summary |
|---|
| public void | run()
LoggingEvent event;
Logger remoteLogger;
try {
if (ois != null) {
while(true) {
// read an event from the wire
event = (LoggingEvent) ois.readObject();
// get a logger from the hierarchy. The name of the logger is taken to be the name contained in the event.
remoteLogger = hierarchy.getLogger(event.getLoggerName());
//event.logger = remoteLogger;
// apply the logger-level filter
if(event.getLevel().isGreaterOrEqual(remoteLogger.getEffectiveLevel())) {
// finally log the event as if was generated locally
remoteLogger.callAppenders(event);
}
}
}
} catch(java.io.EOFException e) {
logger.info("Caught java.io.EOFException closing conneciton.");
} catch(java.net.SocketException e) {
logger.info("Caught java.net.SocketException closing conneciton.");
} catch(IOException e) {
logger.info("Caught java.io.IOException: "+e);
logger.info("Closing connection.");
} catch(Exception e) {
logger.error("Unexpected exception. Closing conneciton.", e);
} finally {
if (ois != null) {
try {
ois.close();
} catch(Exception e) {
logger.info("Could not close connection.", e);
}
}
if (socket != null) {
try {
socket.close();
} catch(IOException ex) {
}
}
}
|
|
