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

Interface EventBundleDispatcher

All Known Implementing Classes:

SimpleEventBundlePipeDispatcher

public interface EventBundleDispatcher

Interface for dispatching EventBundle between different EventBundlePipe

Since:

8.4

Method Summary

Modifier and Type	Method	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

Method Details

init

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

Initialize the dispatcher

Parameters:

pipeDescriptors - descriptors of the underlying EventBundlePipes

sendEventBundle

void sendEventBundle(EventBundle events)

Forward an EventBundle to the underlying EventBundlePipes

waitForCompletion

boolean waitForCompletion(long timeoutMillis)
                   throws InterruptedException

Wait until the end of processing

Throws:

InterruptedException

shutdown

void shutdown()
       throws InterruptedException

Shutdown callback

Throws:

InterruptedException