org.pentaho.platform.plugin.action

Class LocalActionInvoker

java.lang.Object

org.pentaho.platform.scheduler2.action.DefaultActionInvoker

org.pentaho.platform.plugin.action.LocalActionInvoker

All Implemented Interfaces:

IActionInvoker

public class LocalActionInvoker
extends DefaultActionInvoker

A more specific implementation of DefaultActionInvoker for use within a worker node, that massages the param Map keys such that they are generic, and not scheduler specific.

Constructor Summary

Constructors

Constructor and Description
LocalActionInvoker()

Method Summary

Modifier and Type	Method and Description
protected IBackgroundExecutionStreamProvider	getStreamProvider(Map<String,Serializable> params) Gets the stream provider from the INVOKER_STREAMPROVIDER key within the params Map or builds it from the input file and output dir Map values.
IActionInvokeStatus	invokeAction(IAction actionBean, String actionUser, Map<String,Serializable> params)

Methods inherited from class org.pentaho.platform.scheduler2.action.DefaultActionInvoker

invokeActionImpl, isSupportedAction

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalActionInvoker

public LocalActionInvoker()

Method Detail

getStreamProvider

protected IBackgroundExecutionStreamProvider getStreamProvider(Map<String,Serializable> params)

Gets the stream provider from the INVOKER_STREAMPROVIDER key within the params Map or builds it from the input file and output dir Map values. Returns null if information needed to build the stream provider is not present in the map, which is perfectly ok for some IAction types.

Overrides:

getStreamProvider in class DefaultActionInvoker

Parameters:

params - the Map or parameters needed to invoke the IAction

Returns:

a IBackgroundExecutionStreamProvider represented in the params Map

invokeAction

public IActionInvokeStatus invokeAction(IAction actionBean,
                                        String actionUser,
                                        Map<String,Serializable> params)
                                 throws Exception

Specified by:

invokeAction in interface IActionInvoker

Overrides:

invokeAction in class DefaultActionInvoker

Throws:

Exception