org.eclipse.smila.processing.bpel.activities

Class PipeletManager

java.lang.Object

org.eclipse.smila.processing.bpel.activities.PipeletManager

All Implemented Interfaces:

ExtensionBundleProvider, PipeletTrackerListener

public final class PipeletManager
extends java.lang.Object
implements PipeletTrackerListener, ExtensionBundleProvider

Pipelet Manager and Invoker.

Constructor Summary

Constructors

Constructor and Description
PipeletManager()

Method Summary

Methods

Modifier and Type	Method and Description
AbstractExtensionBundle	getExtensionBundle() get extension bundle instance.
void	invokeActivity(java.lang.String activityKey, ExtensionContext context, org.w3c.dom.Element element) invoke a pipelet.
void	pipeletsAdded(java.util.Map<java.lang.String,java.lang.Class<? extends Pipelet>> pipeletClasses) learn about new pipelet classes and instantiate pipelets waiting for their classes.
void	pipeletsRemoved(java.util.Map<java.lang.String,java.lang.Class<? extends Pipelet>> pipeletClasses) forget pipelet classes and remove instances.
void	registerActivity(PipeletHolder pipelet) register a pipelet invocation.
void	setRequestTable(RequestTable requests) method for DS to set a service reference.
void	unsetRequestTable(RequestTable requests) method for DS to unset a service reference.

Methods inherited from class java.lang.Object

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

Constructor Detail

PipeletManager

public PipeletManager()

Method Detail

getExtensionBundle

public AbstractExtensionBundle getExtensionBundle()

Description copied from interface: ExtensionBundleProvider

get extension bundle instance.

Specified by:

getExtensionBundle in interface ExtensionBundleProvider

invokeActivity

public void invokeActivity(java.lang.String activityKey,
                  ExtensionContext context,
                  org.w3c.dom.Element element)

invoke a pipelet.

registerActivity

public void registerActivity(PipeletHolder pipelet)
                      throws ProcessingException

register a pipelet invocation.

Throws:

ProcessingException

pipeletsAdded

public void pipeletsAdded(java.util.Map<java.lang.String,java.lang.Class<? extends Pipelet>> pipeletClasses)

learn about new pipelet classes and instantiate pipelets waiting for their classes. event: the given pipelets are now available for instantiation.

Specified by:

pipeletsAdded in interface PipeletTrackerListener

Parameters:

pipeletClasses - map of pipelet class names to new pipelet classes.

See Also:

PipeletTrackerListener.pipeletsAdded(java.util.Map)

pipeletsRemoved

public void pipeletsRemoved(java.util.Map<java.lang.String,java.lang.Class<? extends Pipelet>> pipeletClasses)

forget pipelet classes and remove instances. event: the given pipelets are not available anymore for instantiation. Current instances should be removed immediately.

Specified by:

pipeletsRemoved in interface PipeletTrackerListener

Parameters:

pipeletClasses - map of pipelet class names to removed pipelet classes.

See Also:

PipeletTrackerListener.pipeletsRemoved(java.util.Map)

setRequestTable

public void setRequestTable(RequestTable requests)

method for DS to set a service reference.

unsetRequestTable

public void unsetRequestTable(RequestTable requests)

method for DS to unset a service reference.