Class AsyncResource

java.lang.Object
org.apache.tika.server.core.resource.AsyncResource

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

  • 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 jakarta.ws.rs.core.HttpHeaders httpHeaders, @Context jakarta.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