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, Set<String> supportedFetchers)

Method Summary

Modifier and Type	Method	Description
ArrayBlockingQueue<EmitData>	getEmitDataQueue(int size)
ArrayBlockingQueue<FetchEmitTuple>	getFetchEmitQueue(int queueSize)
Map<String,Object>	post(InputStream is, javax.ws.rs.core.HttpHeaders httpHeaders, javax.ws.rs.core.UriInfo info)	The client posts a json request.
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,
 Set<String> supportedFetchers)
              throws TikaException,
IOException,
SAXException

Throws:

TikaException

IOException

SAXException

Method Details

getFetchEmitQueue

public ArrayBlockingQueue<FetchEmitTuple> getFetchEmitQueue(int queueSize)

getEmitDataQueue

public ArrayBlockingQueue<EmitData> getEmitDataQueue(int size)

post

@POST
@Produces("application/json")
public Map<String,Object> post(InputStream is,
 @Context
 javax.ws.rs.core.HttpHeaders httpHeaders,
 @Context
 javax.ws.rs.core.UriInfo info)
                        throws Exception

The client posts a json request. At a minimum, this must be a json object that contains an emitter and a fetcherString key with the key to fetch the inputStream. Optionally, it may contain a metadata object that will be used to populate the metadata key for pass through of metadata from the client.

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

Must specify a fetcherString and an emitter in the posted json.

Parameters:

info - uri info

Returns:

InputStream that can be deserialized as a list of Metadata objects

Throws:

Exception

shutdownNow

public void shutdownNow()
                 throws Exception

Throws:

Exception