Package org.apache.logging.log4j.core.appender.routing

Class IdlePurgePolicy

java.lang.Object

org.apache.logging.log4j.core.AbstractLifeCycle

org.apache.logging.log4j.core.appender.routing.IdlePurgePolicy

All Implemented Interfaces:

java.lang.Runnable, PurgePolicy, LifeCycle, LifeCycle2

@Plugin(name="IdlePurgePolicy",
        category="Core",
        printObject=true)
@Scheduled
public class IdlePurgePolicy
extends AbstractLifeCycle
implements PurgePolicy, java.lang.Runnable

Policy is purging appenders that were not in use specified time in minutes

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.logging.log4j.core.LifeCycle

LifeCycle.State

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Long>	appendersUsage
private long	checkInterval
private java.util.concurrent.ScheduledFuture<?>	future
private RoutingAppender	routingAppender
private ConfigurationScheduler	scheduler
private long	timeToLive

Fields inherited from class org.apache.logging.log4j.core.AbstractLifeCycle

DEFAULT_STOP_TIMEOUT, DEFAULT_STOP_TIMEUNIT, LOGGER

Constructor Summary

Constructors

Constructor	Description
IdlePurgePolicy(long timeToLive, long checkInterval, ConfigurationScheduler scheduler)

Method Summary

Modifier and Type	Method	Description
static PurgePolicy	createPurgePolicy(java.lang.String timeToLive, java.lang.String checkInterval, java.lang.String timeUnit, Configuration configuration)	Create the PurgePolicy
void	initialize(RoutingAppender routingAppender)	Initializes with routing appender
void	purge()	Purging appenders that were not in use specified time
void	run()
private void	scheduleNext()
boolean	stop(long timeout, java.util.concurrent.TimeUnit timeUnit)	Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
java.lang.String	toString()
void	update(java.lang.String key, LogEvent event)

Methods inherited from class org.apache.logging.log4j.core.AbstractLifeCycle

equalsImpl, getState, getStatusLogger, hashCodeImpl, initialize, isInitialized, isStarted, isStarting, isStopped, isStopping, setStarted, setStarting, setState, setStopped, setStopping, start, stop, stop

Methods inherited from class java.lang.Object

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

Field Detail

timeToLive

private final long timeToLive

checkInterval

private final long checkInterval

appendersUsage

private final java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Long> appendersUsage

routingAppender

private RoutingAppender routingAppender

scheduler

private final ConfigurationScheduler scheduler

future

private volatile java.util.concurrent.ScheduledFuture<?> future

Constructor Detail

IdlePurgePolicy

public IdlePurgePolicy(long timeToLive,
                       long checkInterval,
                       ConfigurationScheduler scheduler)

Method Detail

initialize

public void initialize(RoutingAppender routingAppender)

Description copied from interface: PurgePolicy

Initializes with routing appender

Specified by:

initialize in interface PurgePolicy

stop

public boolean stop(long timeout,
                    java.util.concurrent.TimeUnit timeUnit)

Description copied from interface: LifeCycle2

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Specified by:

stop in interface LifeCycle2

Overrides:

stop in class AbstractLifeCycle

Parameters:

timeout - the maximum time to wait

timeUnit - the time unit of the timeout argument

Returns:

true if the receiver was stopped cleanly and normally, false otherwise.

purge

public void purge()

Purging appenders that were not in use specified time

Specified by:

purge in interface PurgePolicy

update

public void update(java.lang.String key,
                   LogEvent event)

Specified by:

update in interface PurgePolicy

Parameters:

key - routed appender key

run

public void run()

Specified by:

run in interface java.lang.Runnable

scheduleNext

private void scheduleNext()

createPurgePolicy

@PluginFactory
public static PurgePolicy createPurgePolicy(@PluginAttribute("timeToLive")
                                            java.lang.String timeToLive,
                                            @PluginAttribute("checkInterval")
                                            java.lang.String checkInterval,
                                            @PluginAttribute("timeUnit")
                                            java.lang.String timeUnit,
                                            @PluginConfiguration
                                            Configuration configuration)

Create the PurgePolicy

Parameters:

timeToLive - the number of increments of timeUnit before the Appender should be purged.

checkInterval - when all appenders purged, the number of increments of timeUnit to check if any appenders appeared

timeUnit - the unit of time the timeToLive and the checkInterval is expressed in.

Returns:

The Routes container.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object