com.atlassian.bamboo.index

Class AbstractIndexer.FlushAndUnlockIndexerQueueCallback

java.lang.Object

com.atlassian.bamboo.index.AbstractIndexer.FlushAndUnlockIndexerQueueCallback

All Implemented Interfaces:

com.google.common.util.concurrent.FutureCallback<Long>

Enclosing class:

AbstractIndexer

protected class AbstractIndexer.FlushAndUnlockIndexerQueueCallback
extends Object
implements com.google.common.util.concurrent.FutureCallback<Long>

FutureCallback that will flush and unlock indexer queue after last task has been processed. Single instance of this callback should be created and added to all created ListenableFutureTasks

Constructor Summary

Constructors

Constructor and Description
FlushAndUnlockIndexerQueueCallback(int tasksToProcess, IndexerContext indexerContext)

Method Summary

Modifier and Type	Method and Description
void	onFailure(Throwable t)
void	onSuccess(Long result)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlushAndUnlockIndexerQueueCallback

public FlushAndUnlockIndexerQueueCallback(int tasksToProcess,
                                          IndexerContext indexerContext)

Method Detail

onSuccess

public void onSuccess(Long result)

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<Long>

onFailure

public void onFailure(Throwable t)

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<Long>