org.jboss.logmanager.handlers

Class AsyncHandler

java.lang.Object

java.util.logging.Handler

org.jboss.logmanager.ExtHandler

org.jboss.logmanager.handlers.AsyncHandler

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, FlushableCloseable, Protectable

public class AsyncHandler
extends ExtHandler

An asynchronous log handler which is used to write to a handler or group of handlers which are "slow" or introduce some degree of latency.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	AsyncHandler.AsyncTask
static class	AsyncHandler.OverflowAction

Field Summary

Fields

Modifier and Type	Field and Description
private static int	DEFAULT_QUEUE_LENGTH
private AsyncHandler.OverflowAction	overflowAction
private int	queueLength
private java.util.concurrent.BlockingQueue<ExtLogRecord>	recordQueue
private int	state
private static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AsyncHandler>	stateUpdater
private java.lang.Thread	thread

Fields inherited from class org.jboss.logmanager.ExtHandler

handlers, handlersUpdater

Constructor Summary

Constructors

Constructor and Description
AsyncHandler() Construct a new instance.
AsyncHandler(int queueLength) Construct a new instance.
AsyncHandler(int queueLength, java.util.concurrent.ThreadFactory threadFactory) Construct a new instance.
AsyncHandler(java.util.concurrent.ThreadFactory threadFactory) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
void	close() Close all child handlers.
protected void	doPublish(ExtLogRecord record) Do the actual work of publication; the record will have been filtered already.
AsyncHandler.OverflowAction	getOverflowAction() Get the overflow action.
int	getQueueLength() The full size of the queue.
void	setOverflowAction(AsyncHandler.OverflowAction overflowAction) Set the overflow action.

Methods inherited from class org.jboss.logmanager.ExtHandler

addHandler, checkAccess, checkAccess, clearHandlers, disableAccess, enableAccess, flush, getHandlers, isAutoFlush, isEnabled, protect, publish, publish, removeHandler, setAutoFlush, setEnabled, setEncoding, setErrorManager, setFilter, setFormatter, setHandlers, setLevel, unprotect

Methods inherited from class java.util.logging.Handler

getEncoding, getErrorManager, getFilter, getFormatter, getLevel, isLoggable, reportError

Methods inherited from class java.lang.Object

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

Field Detail

recordQueue

private final java.util.concurrent.BlockingQueue<ExtLogRecord> recordQueue

queueLength

private final int queueLength

thread

private final java.lang.Thread thread

overflowAction

private volatile AsyncHandler.OverflowAction overflowAction

state

private volatile int state

stateUpdater

private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AsyncHandler> stateUpdater

DEFAULT_QUEUE_LENGTH

private static final int DEFAULT_QUEUE_LENGTH

See Also:

Constant Field Values

Constructor Detail

AsyncHandler

public AsyncHandler(int queueLength,
                    java.util.concurrent.ThreadFactory threadFactory)

Construct a new instance.

Parameters:

queueLength - the queue length

threadFactory - the thread factory to use to construct the handler thread

AsyncHandler

public AsyncHandler(java.util.concurrent.ThreadFactory threadFactory)

Construct a new instance.

Parameters:

threadFactory - the thread factory to use to construct the handler thread

AsyncHandler

public AsyncHandler(int queueLength)

Construct a new instance.

Parameters:

queueLength - the queue length

AsyncHandler

public AsyncHandler()

Construct a new instance.

Method Detail

getQueueLength

public int getQueueLength()

The full size of the queue.

Returns:

the full size of the queue.

getOverflowAction

public AsyncHandler.OverflowAction getOverflowAction()

Get the overflow action.

Returns:

the overflow action

setOverflowAction

public void setOverflowAction(AsyncHandler.OverflowAction overflowAction)

Set the overflow action.

Parameters:

overflowAction - the overflow action

doPublish

protected void doPublish(ExtLogRecord record)

Do the actual work of publication; the record will have been filtered already. The default implementation does nothing except to flush if the autoFlush property is set to true; if this behavior is to be preserved in a subclass then this method should be called after the record is physically written.

Overrides:

doPublish in class ExtHandler

Parameters:

record - the log record to publish

close

public void close()
           throws java.lang.SecurityException

Close all child handlers.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class ExtHandler

Throws:

java.lang.SecurityException