org.nuxeo.ecm.core.event.pipe.dispatch

Class SimpleEventBundlePipeDispatcher

java.lang.Object

org.nuxeo.ecm.core.event.pipe.dispatch.SimpleEventBundlePipeDispatcher

All Implemented Interfaces:

EventBundleDispatcher

public class SimpleEventBundlePipeDispatcher
extends Object
implements EventBundleDispatcher

Basic implementation that simply forwards EventBundle to all underlying EventBundlePipe

Since:

8.4

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,String>	parameters
protected List<EventBundlePipe>	pipes

Constructor Summary

Constructors

Constructor and Description
SimpleEventBundlePipeDispatcher()

Method Summary

Modifier and Type	Method and Description
void	init(List<EventPipeDescriptor> pipeDescriptors, Map<String,String> parameters) Initialize the dispatcher
void	sendEventBundle(EventBundle events) Forward an EventBundle to the underlying EventBundlePipes
void	shutdown() Shutdown callback
boolean	waitForCompletion(long timeoutMillis) Wait until the end of processing

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pipes

protected List<EventBundlePipe> pipes

parameters

protected Map<String,String> parameters

Constructor Detail

SimpleEventBundlePipeDispatcher

public SimpleEventBundlePipeDispatcher()

Method Detail

init

public void init(List<EventPipeDescriptor> pipeDescriptors,
                 Map<String,String> parameters)

Description copied from interface: EventBundleDispatcher

Initialize the dispatcher

Specified by:

init in interface EventBundleDispatcher

Parameters:

pipeDescriptors - descriptors of the underlying EventBundlePipes

sendEventBundle

public void sendEventBundle(EventBundle events)

Description copied from interface: EventBundleDispatcher

Forward an EventBundle to the underlying EventBundlePipes

Specified by:

sendEventBundle in interface EventBundleDispatcher

waitForCompletion

public boolean waitForCompletion(long timeoutMillis)
                          throws InterruptedException

Description copied from interface: EventBundleDispatcher

Wait until the end of processing

Specified by:

waitForCompletion in interface EventBundleDispatcher

Returns:

Throws:

InterruptedException

shutdown

public void shutdown()
              throws InterruptedException

Description copied from interface: EventBundleDispatcher

Shutdown callback

Specified by:

shutdown in interface EventBundleDispatcher

Throws:

InterruptedException