public abstract class AbstractPipeConsumer<T> extends Object implements PipeConsumer<T>
PipeConsumer
Modifier and Type | Field and Description |
---|---|
protected String |
name |
protected Map<String,String> |
params |
Constructor and Description |
---|
AbstractPipeConsumer() |
Modifier and Type | Method and Description |
---|---|
protected String |
getName() |
protected Map<String,String> |
getParameters() |
void |
initConsumer(String name,
Map<String,String> params)
Initialize the Consumer when the
EventBundlePipe is initialized |
protected abstract boolean |
processEventBundles(List<EventBundle> bundles) |
boolean |
receiveMessage(List<T> messages)
Callback when a batch of messages is available
|
protected abstract List<EventBundle> |
unmarshallEventBundle(List<T> messages) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
shutdown, waitForCompletion
public AbstractPipeConsumer()
public void initConsumer(String name, Map<String,String> params)
PipeConsumer
EventBundlePipe
is initializedinitConsumer
in interface PipeConsumer<T>
protected Map<String,String> getParameters()
public boolean receiveMessage(List<T> messages)
PipeConsumer
receiveMessage
in interface PipeConsumer<T>
protected abstract List<EventBundle> unmarshallEventBundle(List<T> messages)
protected abstract boolean processEventBundles(List<EventBundle> bundles)
Copyright © 2016 Nuxeo SA. All rights reserved.