com.mulesoft.connectors.internal.source

Class OnNewEmailSource

java.lang.Object

org.mule.runtime.extension.api.runtime.source.Source<T,A>

org.mule.runtime.extension.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>

com.mulesoft.connectors.internal.source.OnNewEmailSource

All Implemented Interfaces:

SourceComponent<org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

@MediaType(value="application/json")
 @DisplayName(value="On New Email")
 @Alias(value="on-new-email-listener")
 @ClusterSupport(value=NOT_SUPPORTED)
 @Summary(value="Enters the flow whenever a new email is received.")
 @MetadataScope(outputResolver=GmailusersmessageslistOutputMetadataResolver.class)
public class OnNewEmailSource
extends org.mule.runtime.extension.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>
implements SourceComponent<org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	logger

Fields inherited from class org.mule.runtime.extension.api.runtime.source.PollingSource

IDS_ON_UPDATED_WATERMARK_OS_NAME_SUFFIX, OS_NAME_MASK, OS_NAME_PREFIX, RECENTLY_PROCESSED_IDS_OS_NAME_SUFFIX, UPDATED_WATERMARK_ITEM_OS_KEY, WATERMARK_ITEM_OS_KEY, WATERMARK_OS_NAME_SUFFIX

Constructor Summary

Constructors

Constructor and Description
OnNewEmailSource()

Method Summary

Modifier and Type	Method and Description
void	accept(org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> context, GmailMessage gmailMessage, GmailWatermark watermark, Optional<com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> httpResponseAttributes)
protected void	doStart()
protected void	doStop()
String	getId()
void	onConnectionException(org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> context, org.mule.runtime.api.connection.ConnectionException exception)
void	onRejectedItem(org.mule.runtime.extension.api.runtime.operation.Result<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> result, org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)
void	poll(org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> pollContext)

Methods inherited from class org.mule.runtime.extension.api.runtime.source.PollingSource

onStart, onStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mulesoft.connectors.internal.source.processor.SourceComponent

createHttpRequest

Field Detail

logger

protected static final org.slf4j.Logger logger

Constructor Detail

OnNewEmailSource

public OnNewEmailSource()

Method Detail

doStart

protected void doStart()
                throws org.mule.runtime.api.exception.MuleException

Specified by:

doStart in class org.mule.runtime.extension.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>

Throws:

org.mule.runtime.api.exception.MuleException

doStop

protected void doStop()

Specified by:

doStop in class org.mule.runtime.extension.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>

poll

public void poll(org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> pollContext)

Specified by:

poll in class org.mule.runtime.extension.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>

onRejectedItem

public void onRejectedItem(org.mule.runtime.extension.api.runtime.operation.Result<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> result,
                           org.mule.runtime.extension.api.runtime.source.SourceCallbackContext callbackContext)

Specified by:

onRejectedItem in class org.mule.runtime.extension.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>

onConnectionException

public void onConnectionException(org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> context,
                                  org.mule.runtime.api.connection.ConnectionException exception)

Specified by:

onConnectionException in interface SourceComponent<org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

accept

public void accept(org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> context,
                   GmailMessage gmailMessage,
                   GmailWatermark watermark,
                   Optional<com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> httpResponseAttributes)

Specified by:

accept in interface SourceComponent<org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

getId

public String getId()

Specified by:

getId in interface SourceComponent<org.mule.runtime.extension.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>