org.mule.modules.marketo

Class BasePagingDelegate<T>

java.lang.Object

org.mule.streaming.ProviderAwarePagingDelegate<T,MarketoConnector>

org.mule.modules.marketo.BasePagingDelegate<T>

Type Parameters:

T - The type returned by the client call that returns the pages.

All Implemented Interfaces:

org.mule.api.Closeable

public abstract class BasePagingDelegate<T>
extends org.mule.streaming.ProviderAwarePagingDelegate<T,MarketoConnector>

Abstract paging delegate used for paginated endpoints that provide nextPageToken and moreResults as part of their responses.

Author:

carlos.martinezledo@mulesoft.com

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	moreResult

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BasePagingDelegate(org.mule.streaming.PagingConfiguration pagingConfiguration, String nextPageToken)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
int	getFetchSize()
String	getNextPageToken()
abstract List<T>	getPage(MarketoConnector provider)
int	getTotalResults(MarketoConnector provider)
List<T>	updateState(MarketoResponse<T> marketoResponse)

Methods inherited from class java.lang.Object

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

Field Detail

moreResult

protected boolean moreResult

Constructor Detail

BasePagingDelegate

protected BasePagingDelegate(org.mule.streaming.PagingConfiguration pagingConfiguration,
                  String nextPageToken)

Method Detail

getPage

public abstract List<T> getPage(MarketoConnector provider)
                         throws Exception

Specified by:

getPage in class org.mule.streaming.ProviderAwarePagingDelegate<T,MarketoConnector>

Throws:

Exception

getTotalResults

public int getTotalResults(MarketoConnector provider)
                    throws Exception

Specified by:

getTotalResults in class org.mule.streaming.ProviderAwarePagingDelegate<T,MarketoConnector>

Throws:

Exception

getFetchSize

public final int getFetchSize()

close

public void close()
           throws org.mule.api.MuleException

Throws:

org.mule.api.MuleException

updateState

public List<T> updateState(MarketoResponse<T> marketoResponse)

getNextPageToken

public String getNextPageToken()