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<java.lang.Long>

Enclosing class:

AbstractIndexer

protected class AbstractIndexer.FlushAndUnlockIndexerQueueCallback
extends java.lang.Object
implements com.google.common.util.concurrent.FutureCallback<java.lang.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

AbstractIndexer.FlushAndUnlockIndexerQueueCallback(int tasksToProcess, IndexerContext indexerContext)

Method Summary

void	onFailure(java.lang.Throwable t)
void	onSuccess(java.lang.Long result)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractIndexer.FlushAndUnlockIndexerQueueCallback

public AbstractIndexer.FlushAndUnlockIndexerQueueCallback(int tasksToProcess,
                                                          IndexerContext indexerContext)

Method Detail

onSuccess

public void onSuccess(java.lang.Long result)

Specified by:

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

onFailure

public void onFailure(java.lang.Throwable t)

Specified by:

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