@Experimental public class LocalEventBundlePipeConsumer extends AbstractListenerPipeConsumer<EventBundle>
WorkManager
asyncExec, stopping
name, params
Constructor and Description |
---|
LocalEventBundlePipeConsumer() |
Modifier and Type | Method and Description |
---|---|
protected List<EventBundle> |
unmarshallEventBundle(List<EventBundle> messages) |
initConsumer, processEventBundles, shutdown, waitForCompletion
getName, getParameters, receiveMessage
public LocalEventBundlePipeConsumer()
protected List<EventBundle> unmarshallEventBundle(List<EventBundle> messages)
unmarshallEventBundle
in class AbstractPipeConsumer<EventBundle>
Copyright © 2016 Nuxeo SA. All rights reserved.