@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(int rangeIndex,
int valueIndex,
String range,
String majorDimension,
List<Object> values) |
org.apache.camel.Exchange |
createExchange(int rangeIndex,
com.google.api.services.sheets.v4.model.ValueRange valueRange) |
org.apache.camel.Exchange |
createExchange(com.google.api.services.sheets.v4.model.Spreadsheet spreadsheet) |
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(int rangeIndex, com.google.api.services.sheets.v4.model.ValueRange valueRange)
public org.apache.camel.Exchange createExchange(int rangeIndex, int valueIndex, String range, String majorDimension, List<Object> values)
public org.apache.camel.Exchange createExchange(com.google.api.services.sheets.v4.model.Spreadsheet spreadsheet)
Apache Camel