@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, setUseFixedDelay
configureConsumer, 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, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public GoogleMailStreamEndpoint(String uri, GoogleMailStreamComponent component, GoogleMailStreamConfiguration endpointConfiguration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public 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) throws UnsupportedEncodingException
UnsupportedEncodingException
Apache Camel