Package org.apache.tika.pipes

Class PipesServer

java.lang.Object

org.apache.tika.pipes.PipesServer

All Implemented Interfaces:

Runnable

public class PipesServer
extends Object
implements Runnable

This server is forked from the PipesClient. This class isolates parsing from the client to protect the primary JVM.

When configuring logging for this class, make absolutely certain not to write to STDOUT. This class uses STDOUT to communicate with the PipesClient.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PipesServer.STATUS

Field Summary

Fields

Modifier and Type	Field	Description
static final int	TIMEOUT_EXIT_CODE

Constructor Summary

Constructors

Constructor	Description
PipesServer(Path tikaConfigPath, InputStream in, PrintStream out, long maxForEmitBatchBytes, long serverParseTimeoutMillis, long serverWaitTimeoutMillis)

Method Summary

Modifier and Type	Method	Description
protected void	initializeResources()
static void	main(String[] args)
protected org.apache.tika.pipes.PipesServer.MetadataListAndEmbeddedBytes	parseFromTuple(FetchEmitTuple t, Fetcher fetcher)
void	processRequests()
void	run()

Methods inherited from class java.lang.Object

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

Field Details

TIMEOUT_EXIT_CODE

public static final int TIMEOUT_EXIT_CODE

See Also:

• Constant Field Values

Constructor Details

PipesServer

public PipesServer(Path tikaConfigPath,
 InputStream in,
 PrintStream out,
 long maxForEmitBatchBytes,
 long serverParseTimeoutMillis,
 long serverWaitTimeoutMillis)
            throws IOException,
TikaException,
SAXException

Throws:

IOException

TikaException

SAXException

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

processRequests

public void processRequests()

parseFromTuple

protected org.apache.tika.pipes.PipesServer.MetadataListAndEmbeddedBytes parseFromTuple(FetchEmitTuple t,
 Fetcher fetcher)

initializeResources

protected void initializeResources()
                            throws TikaException,
IOException,
SAXException

Throws:

TikaException

IOException

SAXException