org.modeshape.graph.search
Class SearchableRepositorySource.ParallelConnection

java.lang.Object
  org.modeshape.graph.search.SearchableRepositorySource.AbstractConnection
      org.modeshape.graph.search.SearchableRepositorySource.ParallelConnection

All Implemented Interfaces:

RepositoryConnection

Enclosing class:

SearchableRepositorySource

@NotThreadSafe
protected class SearchableRepositorySource.ParallelConnection
extends SearchableRepositorySource.AbstractConnection

A RepositoryConnection implementation that calls the delegate processor in a background thread, allowing the processing of the FullTextSearchRequest and AccessQueryRequest objects to be done in this thread and in parallel with other requests.

Constructor Summary

protected

SearchableRepositorySource.ParallelConnection(ExecutorService executorService)

Method Summary

void	execute(ExecutionContext context, Request request) Execute the supplied commands against this repository source.

Methods inherited from class org.modeshape.graph.search.SearchableRepositorySource.AbstractConnection

close, delegateConnection, getDefaultCachePolicy, getSourceName, getXAResource, ping

Methods inherited from class java.lang.Object

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

Constructor Detail

SearchableRepositorySource.ParallelConnection

protected SearchableRepositorySource.ParallelConnection(ExecutorService executorService)

Method Detail

execute

public void execute(ExecutionContext context,
                    Request request)
             throws RepositorySourceException

Execute the supplied commands against this repository source.

Parameters:

context - the environment in which the commands are being executed; never null

request - the request to be executed; never null

Throws:

RepositorySourceException - if there is a problem loading the node data

See Also:

RepositoryConnection.execute(org.modeshape.graph.ExecutionContext, org.modeshape.graph.request.Request)