@UriEndpoint(firstVersion="2.22.0",
scheme="google-mail-stream",
title="Google Mail Stream",
syntax="google-mail-stream:index",
consumerClass=GoogleMailStreamConsumer.class,
consumerOnly=true,
label="api,cloud,mail")
public class GoogleMailStreamEndpoint
extends org.apache.camel.impl.ScheduledPollEndpoint
| Constructor and Description |
|---|
GoogleMailStreamEndpoint(String uri,
GoogleMailStreamComponent component,
GoogleMailStreamConfiguration endpointConfiguration) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(org.apache.camel.ExchangePattern pattern,
com.google.api.services.gmail.model.Message mail) |
org.apache.camel.Producer |
createProducer() |
com.google.api.services.gmail.Gmail |
getClient() |
GoogleMailClientFactory |
getClientFactory() |
GoogleMailStreamConfiguration |
getConfiguration() |
boolean |
isSingleton() |
void |
setClientFactory(GoogleMailClientFactory clientFactory) |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelayconfigureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic GoogleMailStreamEndpoint(String uri, GoogleMailStreamComponent component, GoogleMailStreamConfiguration endpointConfiguration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
Exceptionpublic com.google.api.services.gmail.Gmail getClient()
public GoogleMailClientFactory getClientFactory()
public void setClientFactory(GoogleMailClientFactory clientFactory)
public GoogleMailStreamConfiguration getConfiguration()
public boolean isSingleton()
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern,
com.google.api.services.gmail.model.Message mail)
Apache Camel