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 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

Method Detail

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

Parameters:

events -

waitForCompletion

boolean waitForCompletion(long timeoutMillis)
                   throws InterruptedException

Wait until the end of processing

Parameters:

timeoutMillis -

Returns:

Throws:

InterruptedException

shutdown

void shutdown()
       throws InterruptedException

Shutdown callback

Throws:

InterruptedException