Package org.lsst.ccs.messaging

Class LogBusHandler

java.lang.Object

java.util.logging.Handler

org.lsst.ccs.messaging.LogBusHandler

All Implemented Interfaces:

Closeable, AutoCloseable

public class LogBusHandler
extends Handler
implements Closeable

A java util log Handler that forwards messages to the Log bus. As it may be used in the context of "multi-logging" of the org.lsst.ccs.utilities.logging package it checks for duplicate messages.
Should be a singleton with delegation to a unique static instance (but how to pass the communication layer?) If we share two subsystems on the same JVM the Singleton will not work so it is utmost importance to get the subsystemName directly and create two instances!!!

Author:

bamade

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
protected ExecutorService	executor
protected boolean	logBusInitialized
protected AgentMessagingLayer	messagingAccess
protected String	subSystemName

Constructor Summary

Constructors

Constructor	Description
LogBusHandler(AgentMessagingLayer messagingAccess)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
void	publish(LogRecord record)	should send a LogRecord over the Log Bus.
void	setLevel(Level level)

Methods inherited from class java.util.logging.Handler

getEncoding, getErrorManager, getFilter, getFormatter, getLevel, isLoggable, reportError, setEncoding, setErrorManager, setFilter, setFormatter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

messagingAccess

protected AgentMessagingLayer messagingAccess

closed

protected boolean closed

subSystemName

protected String subSystemName

executor

protected ExecutorService executor

logBusInitialized

protected volatile boolean logBusInitialized

Constructor Details

LogBusHandler

public LogBusHandler(AgentMessagingLayer messagingAccess)

Method Details

publish

public void publish(LogRecord record)

should send a LogRecord over the Log Bus.

Specified by:

publish in class Handler

Parameters:

record -

flush

public void flush()

Specified by:

flush in class Handler

close

public void close()
           throws SecurityException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class Handler

Throws:

SecurityException

setLevel

public void setLevel(Level level)

Overrides:

setLevel in class Handler