com.mulesoft.connectors.internal.source.processor

Class GmailPagingProcessor<T>

java.lang.Object

com.mulesoft.connectors.internal.source.processor.GmailPagingProcessor<T>

public class GmailPagingProcessor<T>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	AFTER_REGEX
protected static String	BEFORE_REGEX
protected static String	GMAIL_API
protected static org.slf4j.Logger	logger
protected static String	MESSAGES_PATH
protected static String	MULTI_SPACE_REGEX

Constructor Summary

Constructors

Constructor and Description
GmailPagingProcessor(ExtendedOAuthRestConnection connection, GmailConfiguration config, SourceComponent<T> sourceComponent, String after, String query)

Method Summary

Modifier and Type	Method and Description
static int	compareMessageIds(String itemMessageId, String watermarkMessageId)
Optional<org.mule.runtime.extension.api.runtime.operation.Result<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>	execute(T pollContext, com.mulesoft.connectivity.rest.commons.internal.util.RestRequestBuilder restRequestBuilder)
void	handleRejectItem(InputStream resultOutputStream)
void	poll(T context, GmailWatermark watermark)
String	prepareQuery(String query)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.slf4j.Logger logger

GMAIL_API

protected static final String GMAIL_API

See Also:

Constant Field Values

MESSAGES_PATH

protected static final String MESSAGES_PATH

See Also:

Constant Field Values

BEFORE_REGEX

protected static final String BEFORE_REGEX

See Also:

Constant Field Values

AFTER_REGEX

protected static final String AFTER_REGEX

See Also:

Constant Field Values

MULTI_SPACE_REGEX

protected static final String MULTI_SPACE_REGEX

See Also:

Constant Field Values

Constructor Detail

GmailPagingProcessor

public GmailPagingProcessor(ExtendedOAuthRestConnection connection,
                            GmailConfiguration config,
                            SourceComponent<T> sourceComponent,
                            String after,
                            String query)

Method Detail

poll

public void poll(T context,
                 GmailWatermark watermark)

prepareQuery

public String prepareQuery(String query)

execute

public Optional<org.mule.runtime.extension.api.runtime.operation.Result<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>> execute(T pollContext,
                                                                                                                                                                          com.mulesoft.connectivity.rest.commons.internal.util.RestRequestBuilder restRequestBuilder)

handleRejectItem

public void handleRejectItem(InputStream resultOutputStream)

compareMessageIds

public static int compareMessageIds(String itemMessageId,
                                    String watermarkMessageId)