net.sf.ehcache.constructs.nonstop.store
Class RejoinAwareBlockingOperation<V>

java.lang.Object
  net.sf.ehcache.constructs.nonstop.store.RejoinAwareBlockingOperation<V>

Type Parameters:

V -

All Implemented Interfaces:

Callable<V>

public class RejoinAwareBlockingOperation<V>
extends Object
implements Callable<V>

A Callable implementation that accepts another callable delegate for executing it in nonstop+rejoin context. Executing the call() operation will execute the delegate callable and block until it returns. On rejoin, the delegate callable is executed again.

Author:

Abhishek Sanoujam

Constructor Summary

RejoinAwareBlockingOperation(ExecutorServiceStore executorServiceStore, Callable<V> callable)
Public constructor

Method Summary

V	call() .
void	clusterRejoined() Called when cluster rejoin happens

Methods inherited from class java.lang.Object

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

Constructor Detail

RejoinAwareBlockingOperation

public RejoinAwareBlockingOperation(ExecutorServiceStore executorServiceStore,
                                    Callable<V> callable)

Public constructor

Parameters:

executorServiceStore -

callable -

Method Detail

call

public V call()
       throws Exception

.

Throws InterruptedException if the executing thread is interrupted before the call returns

Specified by:

call in interface Callable<V>

Throws:

Exception

clusterRejoined

public void clusterRejoined()

Called when cluster rejoin happens