com.atlassian.confluence.event

Class ConfluencePoolBasedEventExecutorFactory

java.lang.Object

com.atlassian.event.internal.AbstractEventExecutorFactory

com.atlassian.event.internal.DirectEventExecutorFactory

com.atlassian.confluence.event.ConfluencePoolBasedEventExecutorFactory

All Implemented Interfaces:

com.atlassian.event.spi.EventExecutorFactory

public class ConfluencePoolBasedEventExecutorFactory
extends com.atlassian.event.internal.DirectEventExecutorFactory

Uses a ThreadPoolExecutor.CallerRunsPolicy for running threads in case if queue is full

Since:

5.3

Constructor Summary

Constructors

Constructor and Description
ConfluencePoolBasedEventExecutorFactory(com.atlassian.event.config.EventThreadPoolConfiguration configuration, com.atlassian.event.internal.EventThreadFactory eventThreadFactory, RejectedExecutionHandler rejectedExecutionHandler)

Method Summary

Modifier and Type	Method and Description
ThreadPoolExecutor	getExecutor()
protected BlockingQueue<Runnable>	getQueue()
RejectedExecutionHandler	getRejectedExecutionHandler()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfluencePoolBasedEventExecutorFactory

public ConfluencePoolBasedEventExecutorFactory(com.atlassian.event.config.EventThreadPoolConfiguration configuration,
                                               com.atlassian.event.internal.EventThreadFactory eventThreadFactory,
                                               RejectedExecutionHandler rejectedExecutionHandler)

Method Detail

getQueue

protected BlockingQueue<Runnable> getQueue()

Overrides:

getQueue in class com.atlassian.event.internal.DirectEventExecutorFactory

getExecutor

public ThreadPoolExecutor getExecutor()

Specified by:

getExecutor in interface com.atlassian.event.spi.EventExecutorFactory

Overrides:

getExecutor in class com.atlassian.event.internal.AbstractEventExecutorFactory

getRejectedExecutionHandler

public RejectedExecutionHandler getRejectedExecutionHandler()