org.fcrepo.indexer

Class AsynchIndexer<Content,Result>

java.lang.Object

org.fcrepo.indexer.AsynchIndexer<Content,Result>

Type Parameters:

Content - the type of content to index

Result - the type of response to expect from an operation

All Implemented Interfaces:

Indexer<Content>

Direct Known Subclasses:

SolrIndexer, SparqlIndexer, SynchIndexer

public abstract class AsynchIndexer<Content,Result>
extends Object
implements Indexer<Content>

An Indexer that executes its operation asynchronously.

Author:

ajs6f

Nested Class Summary

Nested classes/interfaces inherited from interface org.fcrepo.indexer.Indexer

Indexer.IndexerType, Indexer.NoContent

Constructor Summary

Constructors

Constructor and Description
AsynchIndexer()

Method Summary

Methods

Modifier and Type	Method and Description
abstract com.google.common.util.concurrent.ListeningExecutorService	executorService()
com.google.common.util.concurrent.ListenableFuture<Result>	remove(String identifier) Remove the object from the index.
abstract Callable<Result>	removeSynch(String identifier)
com.google.common.util.concurrent.ListenableFuture<Result>	update(String identifier, Content content) Create or update an index entry for the object.
abstract Callable<Result>	updateSynch(String identifier, Content content)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.fcrepo.indexer.Indexer

getIndexerType

Constructor Detail

AsynchIndexer

public AsynchIndexer()

Method Detail

executorService

public abstract com.google.common.util.concurrent.ListeningExecutorService executorService()

Returns:

The ListeningExecutorService to use for operation.

update

public com.google.common.util.concurrent.ListenableFuture<Result> update(String identifier,
                                                                Content content)
                                                                  throws IOException

Description copied from interface: Indexer

Create or update an index entry for the object.

Specified by:

update in interface Indexer<Content>

Returns:

the results of addition

Throws:

IOException

remove

public com.google.common.util.concurrent.ListenableFuture<Result> remove(String identifier)
                                                                  throws IOException

Description copied from interface: Indexer

Remove the object from the index.

Specified by:

remove in interface Indexer<Content>

Returns:

the results of removal

Throws:

IOException

removeSynch

public abstract Callable<Result> removeSynch(String identifier)

Parameters:

identifier -

Returns:

updateSynch

public abstract Callable<Result> updateSynch(String identifier,
                           Content content)

Parameters:

identifier -

content -

Returns: