Package org.apache.tika.pipes.core.server

Class SharedServerResources

java.lang.Object

org.apache.tika.pipes.core.server.SharedServerResources

All Implemented Interfaces:

Closeable, AutoCloseable

public class SharedServerResources
extends Object
implements Closeable

Holds shared resources for a shared PipesServer.

These resources are thread-safe and shared among all ConnectionHandlers:

• AutoDetectParser, Detector - immutable after initialization
• FetcherManager, EmitterManager - use ConcurrentHashMap internally
• MetadataFilter, ContentHandlerFactory - stateless

Method Summary

Modifier and Type	Method	Description
void	close()	Closes what the config loaded and holds open: the filter chain and the engines.
ParseContext	createMergedParseContext(ParseContext requestContext, String presetName)	Creates a merged ParseContext with defaults from tika-config overlaid with request values.
AutoDetectParser	getAutoDetectParser()
ConfigStore	getConfigStore()
ContentHandlerFactory	getDefaultContentHandlerFactory()
MetadataFilter	getDefaultMetadataFilter()
MetadataWriteLimiterFactory	getDefaultMetadataWriteLimiterFactory()
Detector	getDetector()
EmitStrategy	getEmitStrategy()
EmitterManager	getEmitterManager()
ExceptionReporting	getExceptionReporting()
FetcherManager	getFetcherManager()
InferenceDispatcher	getInferenceDispatcher()	Null when no "inference" bindings are configured.
PipesConfig	getPipesConfig()
RecursiveParserWrapper	getRMetaParser()
TikaLoader	getTikaLoader()
static SharedServerResources	load(TikaLoader tikaLoader, PipesConfig pipesConfig)	Loads shared server resources from configuration.

Methods inherited from class java.lang.Object

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

Method Details

load

public static SharedServerResources load(TikaLoader tikaLoader,
 PipesConfig pipesConfig)
                                  throws TikaException,
IOException,
SAXException

Loads shared server resources from configuration.

Parameters:

tikaLoader - the tika loader

pipesConfig - the pipes configuration

Returns:

initialized shared resources

Throws:

TikaException - if initialization fails

IOException - if I/O error occurs

SAXException - if XML parsing error occurs

createMergedParseContext

public ParseContext createMergedParseContext(ParseContext requestContext,
 String presetName)
                                      throws TikaConfigException

Creates a merged ParseContext with defaults from tika-config overlaid with request values.

Parameters:

requestContext - the ParseContext from FetchEmitTuple

presetName - name of the preset to overlay at config-tier trust, or null

Returns:

a new ParseContext with defaults + preset + request overrides

Throws:

TikaConfigException

getTikaLoader

public TikaLoader getTikaLoader()

getPipesConfig

public PipesConfig getPipesConfig()

getAutoDetectParser

public AutoDetectParser getAutoDetectParser()

getDetector

public Detector getDetector()

getRMetaParser

public RecursiveParserWrapper getRMetaParser()

getFetcherManager

public FetcherManager getFetcherManager()

getEmitterManager

public EmitterManager getEmitterManager()

getDefaultMetadataFilter

public MetadataFilter getDefaultMetadataFilter()

close

public void close()
           throws IOException

Closes what the config loaded and holds open: the filter chain and the engines.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getInferenceDispatcher

public InferenceDispatcher getInferenceDispatcher()

Null when no "inference" bindings are configured.

getDefaultContentHandlerFactory

public ContentHandlerFactory getDefaultContentHandlerFactory()

getDefaultMetadataWriteLimiterFactory

public MetadataWriteLimiterFactory getDefaultMetadataWriteLimiterFactory()

getEmitStrategy

public EmitStrategy getEmitStrategy()

getExceptionReporting

public ExceptionReporting getExceptionReporting()

getConfigStore

public ConfigStore getConfigStore()