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

Class AbstractEventBundlePipe<T>

java.lang.Object

org.nuxeo.ecm.core.event.pipe.AbstractEventBundlePipe<T>

All Implemented Interfaces:

EventBundlePipe

Direct Known Subclasses:

LocalEventBundlePipe

public abstract class AbstractEventBundlePipe<T>
extends Object
implements EventBundlePipe

Since:

8.4

Field Summary

Fields

Modifier and Type	Field	Description
protected String	name
protected Map<String,String>	params

Constructor Summary

Constructors

Constructor	Description
AbstractEventBundlePipe()

Method Summary

Modifier and Type	Method	Description
protected EventBundle	filterBundle(EventBundle events)
protected String	getName()
protected Map<String,String>	getParameters()
void	initPipe(String name, Map<String,String> params)	Initialize the Pipe when Nuxeo Event Service starts
protected abstract T	marshall(EventBundle events)	de-hydrate the EventBundle to make it suitable for transmission on a Bus
protected void	preProcessBundle(EventBundle events)
protected abstract void	send(T message)	Do the actual push on the Bus
void	sendEventBundle(EventBundle events)	Send an EventBundle inside the pipe
void	shutdown()	Shutdown callback when the EventService stops

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.ecm.core.event.pipe.EventBundlePipe

waitForCompletion

Field Detail

name

protected String name

params

protected Map<String,String> params

Constructor Detail

AbstractEventBundlePipe

public AbstractEventBundlePipe()

Method Detail

initPipe

public void initPipe(String name,
                     Map<String,String> params)

Description copied from interface: EventBundlePipe

Initialize the Pipe when Nuxeo Event Service starts

Specified by:

initPipe in interface EventBundlePipe

Parameters:

name - the name as defined in the XMap descriptor

params - the parameters as defined in the XMap descriptor

getName

protected String getName()

getParameters

protected Map<String,String> getParameters()

sendEventBundle

public void sendEventBundle(EventBundle events)

Description copied from interface: EventBundlePipe

Send an EventBundle inside the pipe

Specified by:

sendEventBundle in interface EventBundlePipe

filterBundle

protected EventBundle filterBundle(EventBundle events)

preProcessBundle

protected void preProcessBundle(EventBundle events)

marshall

protected abstract T marshall(EventBundle events)

de-hydrate the EventBundle to make it suitable for transmission on a Bus

send

protected abstract void send(T message)

Do the actual push on the Bus

shutdown

public void shutdown()
              throws InterruptedException

Description copied from interface: EventBundlePipe

Shutdown callback when the EventService stops

Specified by:

shutdown in interface EventBundlePipe

Throws:

InterruptedException