com.arakelian.elastic.bulk

Class BlockCallerPolicy

java.lang.Object

com.arakelian.elastic.bulk.BlockCallerPolicy

All Implemented Interfaces:

java.util.concurrent.RejectedExecutionHandler

public final class BlockCallerPolicy
extends java.lang.Object
implements java.util.concurrent.RejectedExecutionHandler

Executor policy that blocks caller to execute task.

Constructor Summary

Constructors

Constructor and Description
BlockCallerPolicy()

Method Summary

Modifier and Type	Method and Description
void	rejectedExecution(java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor executor)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockCallerPolicy

public BlockCallerPolicy()

Method Detail

rejectedExecution

public void rejectedExecution(java.lang.Runnable r,
                              java.util.concurrent.ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface java.util.concurrent.RejectedExecutionHandler