org.apache.tika.batch

Class ConsumersManager

java.lang.Object

org.apache.tika.batch.ConsumersManager

Direct Known Subclasses:

FSConsumersManager

public abstract class ConsumersManager
extends java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<FileResourceConsumer>	consumers
private long	consumersManagerMaxMillis

Constructor Summary

Constructors

Constructor and Description
ConsumersManager(java.util.List<FileResourceConsumer> consumers)

Method Summary

Modifier and Type	Method and Description
java.util.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

Field Detail

consumersManagerMaxMillis

private long consumersManagerMaxMillis

consumers

private final java.util.List<FileResourceConsumer> consumers

Constructor Detail

ConsumersManager

public ConsumersManager(java.util.List<FileResourceConsumer> consumers)

Method Detail

getConsumers

public java.util.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()