Package org.apache.tika.server.core.resource

Class AsyncResource

java.lang.Object

org.apache.tika.server.core.resource.AsyncResource

@Path("/async")
public class AsyncResource
extends Object

Constructor Summary

Constructors

Constructor	Description
AsyncResource(Path tikaConfigPath)

Method Summary

Modifier and Type	Method	Description
ArrayBlockingQueue<EmitDataImpl>	getEmitDataQueue(int size)
ArrayBlockingQueue<FetchEmitTuple>	getFetchEmitQueue(int queueSize)
jakarta.ws.rs.core.Response	post(InputStream is, jakarta.ws.rs.core.HttpHeaders httpHeaders, jakarta.ws.rs.core.UriInfo info)	The client posts a JSON object {"tuples":[...]}.
void	setMaxQueuePauseMillis(long maxQueuePauseMillis)	How long a full /async queue blocks a POST before returning 429; see TikaServerConfig.
void	shutdownNow()

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncResource

public AsyncResource(Path tikaConfigPath)
              throws TikaException,
IOException,
SAXException

Throws:

TikaException

IOException

SAXException

Method Details

setMaxQueuePauseMillis

public void setMaxQueuePauseMillis(long maxQueuePauseMillis)

How long a full /async queue blocks a POST before returning 429; see TikaServerConfig.

getFetchEmitQueue

public ArrayBlockingQueue<FetchEmitTuple> getFetchEmitQueue(int queueSize)

getEmitDataQueue

public ArrayBlockingQueue<EmitDataImpl> getEmitDataQueue(int size)

post

@POST
@Produces("application/json")
public jakarta.ws.rs.core.Response post(InputStream is,
 @Context
 jakarta.ws.rs.core.HttpHeaders httpHeaders,
 @Context
 jakarta.ws.rs.core.UriInfo info)
                                 throws Exception

The client posts a JSON object {"tuples":[...]}. Each tuple names a fetcher and fetch key for input and an emitter for output; it may also carry a metadata object (passed through to the emitted metadata) and a parse context.

The extracted text content is stored with the key TikaCoreProperties.TIKA_CONTENT

Parameters:

info - uri info

Returns:

JSON body reporting acceptance ({"status":"ok","added":n}); the parses themselves run asynchronously

Throws:

Exception

shutdownNow

public void shutdownNow()
                 throws Exception

Throws:

Exception