SMILA (incubation) API documentation

org.eclipse.smila.processing.bpel
Class PipeletManager

java.lang.Object
  extended by org.eclipse.smila.processing.bpel.PipeletManager
All Implemented Interfaces:
PipeletTrackerListener

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

Pipelet Manager and Invoker.

Author:
jschumacher

Method Summary
 void checkAvailability(PipeletHolder pipeletHolder, ODEWorkflowProcessor processor)
          check if pipelet invoked is already available.
 PipeletHolder doRegisterActivity(OProcess pipelineProcess, OExtensionActivity activity, org.w3c.dom.Element content, java.lang.String key)
          register extension actvity.
static PipeletManager getInstance()
          singleton instance access method.
 void invokeActivity(ExtensionContext context, org.w3c.dom.Element element)
          invoke extension activity from BPEL process.
 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(OExtensionActivity activity, ExtensibleElement element)
          create adapter for detected extension activity.
 void registerAsListener(BundleContext context)
          register this object as a listener to pipelet change events by PipeletTracker.
 void registerPipeline(ODEWorkflowProcessor processor, javax.xml.namespace.QName processName)
          register owner of pipeline.
 void unregisterPipeline(javax.xml.namespace.QName processName)
          register owner of pipeline.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInstance

public static PipeletManager getInstance()
singleton instance access method.

Returns:
singleton instance of SimpletonPipeletManager

registerAsListener

public void registerAsListener(BundleContext context)
register this object as a listener to pipelet change events by PipeletTracker.

Parameters:
context - bundle context.

doRegisterActivity

public PipeletHolder doRegisterActivity(OProcess pipelineProcess,
                                        OExtensionActivity activity,
                                        org.w3c.dom.Element content,
                                        java.lang.String key)
register extension actvity. Should throw a org.apache.ode.bpel.compiler.api.CompilationException if an error occurs.

Parameters:
pipelineProcess - process that contains the activity.
activity - the activity to register
content - XML content of actvity
key - key of actvity
Returns:
adapter for activity.

checkAvailability

public void checkAvailability(PipeletHolder pipeletHolder,
                              ODEWorkflowProcessor processor)
                       throws ProcessingException
check if pipelet invoked is already available.

Parameters:
pipeletHolder - contains pipelet to check
processor - associated processor
Throws:
ProcessingException - if elements represented by adapter cannot be invoked.

invokeActivity

public void invokeActivity(ExtensionContext context,
                           org.w3c.dom.Element element)
invoke extension activity from BPEL process.

Parameters:
context - BPEL extension context.
element - DOM representation of extension element.

registerPipeline

public void registerPipeline(ODEWorkflowProcessor processor,
                             javax.xml.namespace.QName processName)
register owner of pipeline.

Parameters:
processor - ODE processor that owns this pipeline.
processName - pipeline to register

unregisterPipeline

public void unregisterPipeline(javax.xml.namespace.QName processName)
register owner of pipeline.

Parameters:
processName - pipeline to register

registerActivity

public void registerActivity(OExtensionActivity activity,
                             ExtensibleElement element)
create adapter for detected extension activity. Throws a org.apache.ode.bpel.compiler.api.CompilationException if an error occurs.

Parameters:
activity - the activity to register
element - DOM element from BPEL describing the activity

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)

SMILA (incubation) API documentation