org.apache.tika.batch

Class ConsumersManager

java.lang.Object

org.apache.tika.batch.ConsumersManager

Direct Known Subclasses:

FSConsumersManager

public abstract class ConsumersManager
extends Object

Simple interface around a collection of consumers that allows for initializing and shutting shared resources (e.g. db connection, index, writer, etc.)

Constructor Summary

Constructors

Constructor and Description
ConsumersManager(List<FileResourceConsumer> consumers)

Method Summary

Modifier and Type	Method and Description
List<FileResourceConsumer>	getConsumers() Get the consumers
long	getConsumersManagerMaxMillis() BatchProcess will throw an exception if the ConsumersManager doesn't complete init() or shutdown() within this amount of time.
void	init() This is called by BatchProcess before submitting the threads
void	setConsumersManagerMaxMillis(long consumersManagerMaxMillis) getConsumersManagerMaxMillis()
void	shutdown() This is called by BatchProcess immediately before closing.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumersManager

public ConsumersManager(List<FileResourceConsumer> consumers)

Method Detail

getConsumers

public List<FileResourceConsumer> getConsumers()

Get the consumers

Returns:

consumers

init

public void init()

This is called by BatchProcess before submitting the threads

shutdown

public void shutdown()

This is called by BatchProcess immediately before closing. Beware! Some of the consumers may have hung or may not have completed.

getConsumersManagerMaxMillis

public long getConsumersManagerMaxMillis()

BatchProcess will throw an exception if the ConsumersManager doesn't complete init() or shutdown() within this amount of time.

Returns:

the maximum time allowed for init() or shutdown()

setConsumersManagerMaxMillis

public void setConsumersManagerMaxMillis(long consumersManagerMaxMillis)

getConsumersManagerMaxMillis()

Parameters:

consumersManagerMaxMillis - maximum number of milliseconds to allow for init() or shutdown()