org.mule.extension.internal.dataloading

Class DataLoaderSource

java.lang.Object

org.mule.runtime.extension.api.runtime.source.Source<InputPayload,InputAttr>

org.mule.extension.internal.apikit.ApikitSource<Set<Object>,DataLoaderAttributes,org.mule.runtime.api.metadata.TypedValue<Object>>

org.mule.extension.internal.dataloading.DataLoaderSource

@MetadataScope(outputResolver=DataLoaderMetadataResolver.class)
 @Alias(value="DataLoader")
 @EmitsResponse
public class DataLoaderSource
extends ApikitSource<Set<Object>,DataLoaderAttributes,org.mule.runtime.api.metadata.TypedValue<Object>>

Data loader source.

When used as the source for a flow it pushes a list of keys as its attributes.

When the flow completes it expects a list of the same size, where the i-th element is the result for the i-th key.

Constructor Summary

Constructors

Constructor and Description
DataLoaderSource()

Method Summary

Modifier and Type	Method and Description
protected DataLoadingRoutingKey	getKey()
void	onSuccess(org.mule.runtime.api.metadata.TypedValue<Object> bodyContent, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext, org.mule.runtime.extension.api.runtime.source.SourceCompletionCallback completionCallback)

Methods inherited from class org.mule.extension.internal.apikit.ApikitSource

convert, failure, onError, onStart, onStop, onTerminate, success

Methods inherited from class java.lang.Object

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

Constructor Detail

DataLoaderSource

public DataLoaderSource()

Method Detail

getKey

protected DataLoadingRoutingKey getKey()

Specified by:

getKey in class ApikitSource<Set<Object>,DataLoaderAttributes,org.mule.runtime.api.metadata.TypedValue<Object>>

Returns:

the key that identifies the Source

onSuccess

@OnSuccess
public void onSuccess(@Placement(tab="Responses",order=1) @Content
                                 org.mule.runtime.api.metadata.TypedValue<Object> bodyContent,
                                 org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext,
                                 org.mule.runtime.extension.api.runtime.source.SourceCompletionCallback completionCallback)