Class AsyncEmitter

java.lang.Object

org.apache.tika.pipes.core.async.AsyncEmitter

All Implemented Interfaces:

Callable<Integer>

public class AsyncEmitter
extends Object
implements Callable<Integer>

Worker thread that takes EmitData off the queue, batches it and tries to emit it as a batch

Constructor Summary

Constructors

Constructor	Description
AsyncEmitter(PipesConfig asyncConfig, ArrayBlockingQueue<EmitDataPair> emitData, EmitterManager emitterManager)

Method Summary

Modifier and Type	Method	Description
Integer	call()

Methods inherited from class Object

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

Constructor Details

AsyncEmitter

public AsyncEmitter(PipesConfig asyncConfig,
 ArrayBlockingQueue<EmitDataPair> emitData,
 EmitterManager emitterManager)

Method Details

call

public Integer call()
             throws Exception

Specified by:

call in interface Callable<Integer>

Throws:

Exception