public abstract class AbstractDevkitBasedPageableMessageProcessor extends DevkitBasedMessageProcessor
PagingDelegate
and returning a ConsumerIterator
accordinglyflowConstruct, moduleObject, muleContext
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
AbstractDevkitBasedPageableMessageProcessor(String operationName) |
Modifier and Type | Method and Description |
---|---|
protected MuleEvent |
doProcess(MuleEvent event)
This method sets the message payload to an instance of
ConsumerIterator configured
accordingly to the configured outputUnit and the
PagingDelegate obtained by invoking getPagingDelegate(org.mule.api.MuleEvent, org.mule.streaming.PagingConfiguration) |
protected abstract PagingDelegate<?> |
getPagingDelegate(MuleEvent event,
PagingConfiguration pagingConfiguration)
Implement this method to return the
PagingDelegate
to be used when paging. |
void |
setFetchSize(String fetchSize) |
dispose, findOrCreate, getAccessTokenId, getFlowConstruct, getMuleContext, initialise, overwritePayload, process, setAccessTokenId, setFlowConstruct, setModuleObject, setMuleContext, start, stop
computeClassHierarchy, evaluate, evaluateAndTransform, evaluateAndTransform, getAccessTokenId, isAssignableFrom, isList, isListClass, isMap, isMapClass, transform, transform, transform
public AbstractDevkitBasedPageableMessageProcessor(String operationName)
protected final MuleEvent doProcess(MuleEvent event) throws Exception
ConsumerIterator
configured
accordingly to the configured outputUnit and the
PagingDelegate
obtained by invoking getPagingDelegate(org.mule.api.MuleEvent, org.mule.streaming.PagingConfiguration)
doProcess
in class DevkitBasedMessageProcessor
event
- the mule eventMuleEvent
IllegalArgumentException
- is firstPage is lower than zero or if
lastPage is lower than zero and firstPage or if fetchSize is lower
than zeroException
protected abstract PagingDelegate<?> getPagingDelegate(MuleEvent event, PagingConfiguration pagingConfiguration) throws Exception
PagingDelegate
to be used when paging. This method should never return null
event
- the current mule eventpagingConfiguration
- paging configuration parametersPagingDelegate
Exception
public void setFetchSize(String fetchSize)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.