org.mule.extension.email.internal.commands

Class PagingProviderEmailDelegate<T extends BaseEmailAttributes>

java.lang.Object

org.mule.extension.email.internal.commands.PagingProviderEmailDelegate<T>

All Implemented Interfaces:

Closeable, AutoCloseable, org.mule.runtime.extension.api.runtime.streaming.PagingProvider<MailboxConnection,org.mule.runtime.extension.api.runtime.operation.Result<Object,T>>

public final class PagingProviderEmailDelegate<T extends BaseEmailAttributes>
extends Object
implements org.mule.runtime.extension.api.runtime.streaming.PagingProvider<MailboxConnection,org.mule.runtime.extension.api.runtime.operation.Result<Object,T>>

PagingProvider implementation for list emails operation.

Since:

4.0

Constructor Summary

Constructors

Constructor and Description
PagingProviderEmailDelegate(MailboxAccessConfiguration configuration, String folderName, BaseEmailPredicateBuilder matcherBuilder, int pageSize, boolean deleteAfterRetrieve, Consumer<BaseEmailAttributes> deleteAfterReadCallback)

Method Summary

Modifier and Type	Method and Description
void	close()
List<org.mule.runtime.extension.api.runtime.operation.Result<Object,T>>	getPage(MailboxConnection connection)
Optional<Integer>	getTotalResults(MailboxConnection connection)

Methods inherited from class java.lang.Object

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

Constructor Detail

PagingProviderEmailDelegate

public PagingProviderEmailDelegate(MailboxAccessConfiguration configuration,
                                   String folderName,
                                   BaseEmailPredicateBuilder matcherBuilder,
                                   int pageSize,
                                   boolean deleteAfterRetrieve,
                                   Consumer<BaseEmailAttributes> deleteAfterReadCallback)

Parameters:

configuration - The MailboxAccessConfiguration associated to this operation.

folderName - the name of the folder where the emails are stored.

matcherBuilder - a Predicate of BaseEmailAttributes used to filter the output list @return a List of Message carrying all the emails and it's corresponding attributes.

pageSize - size of the block that would be retrieved from the email server. This page doesn't represent the page size to be returned by the PagingProvider because emails must be tested against the BaseEmailPredicateBuilder matcher after retrieval to see if they fulfill matcher's condition.

deleteAfterRetrieve - whether the emails should be deleted after retrieval

deleteAfterReadCallback - callback for deleting each email

Method Detail

getPage

public List<org.mule.runtime.extension.api.runtime.operation.Result<Object,T>> getPage(MailboxConnection connection)

Specified by:

getPage in interface org.mule.runtime.extension.api.runtime.streaming.PagingProvider<MailboxConnection,org.mule.runtime.extension.api.runtime.operation.Result<Object,T extends BaseEmailAttributes>>

getTotalResults

public Optional<Integer> getTotalResults(MailboxConnection connection)

Specified by:

getTotalResults in interface org.mule.runtime.extension.api.runtime.streaming.PagingProvider<MailboxConnection,org.mule.runtime.extension.api.runtime.operation.Result<Object,T extends BaseEmailAttributes>>

Parameters:

connection - The connection to be used to do the query.

Returns:

Optional.empty() because a priori there is no way for knowing how many emails are going to be tested true against the BaseEmailPredicateBuilder matcher.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException