@UriEndpoint(firstVersion="2.23.0", scheme="google-sheets-stream", title="Google Sheets Stream", syntax="google-sheets-stream:apiName", consumerClass=GoogleSheetsStreamConsumer.class, consumerOnly=true, label="api,cloud,sheets") public class GoogleSheetsStreamEndpoint extends org.apache.camel.impl.ScheduledPollEndpoint
Constructor and Description |
---|
GoogleSheetsStreamEndpoint(String uri,
GoogleSheetsStreamComponent component,
GoogleSheetsStreamConfiguration endpointConfiguration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(com.google.api.services.sheets.v4.model.Spreadsheet spreadsheet) |
org.apache.camel.Exchange |
createExchange(com.google.api.services.sheets.v4.model.ValueRange valueRange) |
org.apache.camel.Producer |
createProducer() |
com.google.api.services.sheets.v4.Sheets |
getClient() |
GoogleSheetsClientFactory |
getClientFactory() |
GoogleSheetsStreamConfiguration |
getConfiguration() |
boolean |
isSingleton() |
void |
setClientFactory(GoogleSheetsClientFactory 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 GoogleSheetsStreamEndpoint(String uri, GoogleSheetsStreamComponent component, GoogleSheetsStreamConfiguration endpointConfiguration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public com.google.api.services.sheets.v4.Sheets getClient()
public GoogleSheetsClientFactory getClientFactory()
public void setClientFactory(GoogleSheetsClientFactory clientFactory)
public GoogleSheetsStreamConfiguration getConfiguration()
public boolean isSingleton()
public org.apache.camel.Exchange createExchange(com.google.api.services.sheets.v4.model.ValueRange valueRange)
public org.apache.camel.Exchange createExchange(com.google.api.services.sheets.v4.model.Spreadsheet spreadsheet)
Apache Camel