com.mulesoft.connectors.internal.source.sidecar

Class OnNewEmailCitizenSource

java.lang.Object

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

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

com.mulesoft.connectors.internal.source.sidecar.OnNewEmailCitizenSource

All Implemented Interfaces:

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

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

Field Summary

Fields inherited from class org.mule.sdk.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
OnNewEmailCitizenSource()

Method Summary

Modifier and Type	Method and Description
void	accept(org.mule.sdk.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)
org.mule.runtime.http.api.domain.message.request.HttpRequest	createHttpRequest(org.mule.runtime.http.api.domain.message.request.HttpRequestBuilder builder) For citizen we return only subset of response information to the user se we filter out unnecessary data in the request.
protected void	doStart()
protected void	doStop()
String	getId()
void	onConnectionException(org.mule.sdk.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.sdk.api.runtime.operation.Result<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> result, org.mule.sdk.api.runtime.source.SourceCallbackContext sourceCallbackContext)
void	poll(org.mule.sdk.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes> pollContext)

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

onStart, onStop

Methods inherited from class java.lang.Object

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

Constructor Detail

OnNewEmailCitizenSource

public OnNewEmailCitizenSource()

Method Detail

doStart

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

Specified by:

doStart in class org.mule.sdk.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.sdk.api.runtime.source.PollingSource<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>

poll

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

Specified by:

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

onConnectionException

public void onConnectionException(org.mule.sdk.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.sdk.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

accept

public void accept(org.mule.sdk.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.sdk.api.runtime.source.PollContext<InputStream,com.mulesoft.connectivity.rest.commons.api.operation.HttpResponseAttributes>>

onRejectedItem

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

Specified by:

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

getId

public String getId()

Specified by:

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

createHttpRequest

public org.mule.runtime.http.api.domain.message.request.HttpRequest createHttpRequest(org.mule.runtime.http.api.domain.message.request.HttpRequestBuilder builder)

For citizen we return only subset of response information to the user se we filter out unnecessary data in the request.

Specified by:

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

Returns:

HttpRequest