@Path(value="/async") public class AsyncResource extends Object
Constructor and Description |
---|
AsyncResource(Path tikaConfigPath,
Set<String> supportedFetchers) |
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() |
public AsyncResource(Path tikaConfigPath, Set<String> supportedFetchers) throws TikaException, IOException, SAXException
TikaException
IOException
SAXException
public ArrayBlockingQueue<FetchEmitTuple> getFetchEmitQueue(int queueSize)
public ArrayBlockingQueue<EmitData> getEmitDataQueue(int size)
@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 extracted text content is stored with the key
TikaCoreProperties.TIKA_CONTENT
Must specify a fetcherString and an emitter in the posted json.
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.