public abstract class ConsumersManager extends Object
Constructor and Description |
---|
ConsumersManager(List<FileResourceConsumer> consumers) |
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) |
void |
shutdown()
This is called by BatchProcess immediately before closing.
|
public ConsumersManager(List<FileResourceConsumer> consumers)
public List<FileResourceConsumer> getConsumers()
public void init()
public void shutdown()
public long getConsumersManagerMaxMillis()
BatchProcess
will throw an exception
if the ConsumersManager doesn't complete init() or shutdown()
within this amount of time.public void setConsumersManagerMaxMillis(long consumersManagerMaxMillis)
consumersManagerMaxMillis
- maximum number of milliseconds
to allow for init() or shutdown()getConsumersManagerMaxMillis()
Copyright © 2007–1969 The Apache Software Foundation. All rights reserved.