public interface PipeConsumer<T>
EventBundlePipe
Modifier and Type | Method and Description |
---|---|
void |
initConsumer(String name,
Map<String,String> params)
Initialize the Consumer when the
EventBundlePipe is initialized |
boolean |
receiveMessage(List<T> messages)
Callback when a batch of messages is available
|
void |
shutdown()
Shutdown the consumer when the
EventBundlePipe is shutdown |
boolean |
waitForCompletion(long timeoutMillis)
Wait until consumer is done
|
void initConsumer(String name, Map<String,String> params)
EventBundlePipe
is initializedname
- params
- boolean receiveMessage(List<T> messages)
messages
- void shutdown() throws InterruptedException
EventBundlePipe
is shutdownInterruptedException
boolean waitForCompletion(long timeoutMillis) throws InterruptedException
timeoutMillis
- InterruptedException
Copyright © 2017 Nuxeo. All rights reserved.