public class FSConsumersManager extends ConsumersManager
Constructor and Description |
---|
FSConsumersManager(List<FileResourceConsumer> consumers) |
Modifier and Type | Method and Description |
---|---|
void |
init()
This is called by BatchProcess before submitting the threads
|
void |
shutdown()
This is called by BatchProcess immediately before closing.
|
getConsumers, getConsumersManagerMaxMillis, setConsumersManagerMaxMillis
public FSConsumersManager(List<FileResourceConsumer> consumers)
public void init()
ConsumersManager
init
in class ConsumersManager
public void shutdown()
ConsumersManager
shutdown
in class ConsumersManager
Copyright © 2007-2015 The Apache Software Foundation. All Rights Reserved.