public class RejectedReplicationTaskHandler extends Object implements RejectedExecutionHandler
Modifier and Type | Field and Description |
---|---|
static org.apache.log4j.Logger |
log |
Constructor and Description |
---|
RejectedReplicationTaskHandler()
Constructor to create a rejected replication task handler instance
|
Modifier and Type | Method and Description |
---|---|
void |
rejectedExecution(Runnable replicationTask,
ThreadPoolExecutor executor)
A handler method that adds rejected replication tasks back into the
Hazelcast replication task queue to be completed later or by another
coordinating node that may pick it up from the queue.
|
public RejectedReplicationTaskHandler()
public void rejectedExecution(Runnable replicationTask, ThreadPoolExecutor executor)
rejectedExecution
in interface RejectedExecutionHandler
Copyright © 2018. All rights reserved.