org.apache.tika.server.core.resource

Class AsyncResource

java.lang.Object

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

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

Constructor Summary

Constructors

Constructor and Description
AsyncResource(Path tikaConfigPath, Set<String> supportedFetchers)

Method Summary

Modifier and Type	Method and 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 Detail

AsyncResource

public AsyncResource(Path tikaConfigPath,
                     Set<String> supportedFetchers)
              throws TikaException,
                     IOException,
                     SAXException

Throws:

TikaException

IOException

SAXException

Method Detail

getFetchEmitQueue

public ArrayBlockingQueue<FetchEmitTuple> getFetchEmitQueue(int queueSize)

getEmitDataQueue

public ArrayBlockingQueue<EmitData> getEmitDataQueue(int size)

post

@POST
 @Produces(value="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