@UriEndpoint(firstVersion="2.19.0", scheme="couchbase", title="Couchbase", syntax="couchbase:protocol:hostname:port", consumerClass=CouchbaseConsumer.class, label="database,nosql") public class CouchbaseEndpoint extends org.apache.camel.impl.ScheduledPollEndpoint
Constructor and Description |
---|
CouchbaseEndpoint() |
CouchbaseEndpoint(String endpointUri,
CouchbaseComponent component) |
CouchbaseEndpoint(String uri,
String remaining,
CouchbaseComponent component) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
String |
getAdditionalHosts() |
String |
getBucket() |
String |
getConsumerProcessedStrategy() |
String |
getDesignDocumentName() |
String |
getHostname() |
String |
getKey() |
int |
getLimit() |
long |
getMaxReconnectDelay() |
long |
getObsPollInterval() |
long |
getObsTimeout() |
String |
getOperation() |
long |
getOpQueueMaxBlockTime() |
long |
getOpTimeOut() |
String |
getPassword() |
int |
getPersistTo() |
int |
getPort() |
int |
getProducerRetryAttempts() |
int |
getProducerRetryPause() |
String |
getProtocol() |
String |
getRangeEndKey() |
String |
getRangeStartKey() |
int |
getReadBufferSize() |
int |
getReplicateTo() |
int |
getSkip() |
long |
getStartingIdForInsertsFrom() |
int |
getTimeoutExceptionThreshold() |
String |
getUsername() |
String |
getViewName() |
boolean |
isAutoStartIdForInserts() |
boolean |
isDescending() |
boolean |
isShouldOptimize() |
boolean |
isSingleton() |
URI[] |
makeBootstrapURI() |
void |
setAdditionalHosts(String additionalHosts)
The additional hosts
|
void |
setAutoStartIdForInserts(boolean autoStartIdForInserts)
Define if we want an autostart Id when we are doing an insert operation
|
void |
setBucket(String bucket)
The bucket to use
|
void |
setConsumerProcessedStrategy(String consumerProcessedStrategy)
Define the consumer Processed strategy to use
|
void |
setDescending(boolean descending)
Define if this operation is descending or not
|
void |
setDesignDocumentName(String designDocumentName)
The design document name to use
|
void |
setHostname(String hostname)
The hostname to use
|
void |
setKey(String key)
The key to use
|
void |
setLimit(int limit)
The output limit to use
|
void |
setMaxReconnectDelay(long maxReconnectDelay)
Define the max delay during a reconnection
|
void |
setObsPollInterval(long obsPollInterval)
Define the observation polling interval
|
void |
setObsTimeout(long obsTimeout)
Define the observation timeout
|
void |
setOperation(String operation)
The operation to do
|
void |
setOpQueueMaxBlockTime(long opQueueMaxBlockTime)
Define the max time an operation can be in queue blocked
|
void |
setOpTimeOut(long opTimeOut)
Define the operation timeout
|
void |
setPassword(String password)
The password to use
|
void |
setPersistTo(int persistTo)
Where to persist the data
|
void |
setPort(int port)
The port number to use
|
void |
setProducerRetryAttempts(int producerRetryAttempts)
Define the number of retry attempts
|
void |
setProducerRetryPause(int producerRetryPause)
Define the retry pause between different attempts
|
void |
setProtocol(String protocol)
The protocol to use
|
void |
setRangeEndKey(String rangeEndKey)
Define a range for the end key
|
void |
setRangeStartKey(String rangeStartKey)
Define a range for the start key
|
void |
setReadBufferSize(int readBufferSize)
Define the buffer size
|
void |
setReplicateTo(int replicateTo)
Where to replicate the data
|
void |
setShouldOptimize(boolean shouldOptimize)
Define if we want to use optimization or not where possible
|
void |
setSkip(int skip)
Define the skip to use
|
void |
setStartingIdForInsertsFrom(long startingIdForInsertsFrom)
Define the starting Id where we are doing an insert operation
|
void |
setTimeoutExceptionThreshold(int timeoutExceptionThreshold)
Define the threshold for throwing a timeout Exception
|
void |
setUsername(String username)
The username to use
|
void |
setViewName(String viewName)
The view name to use
|
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 CouchbaseEndpoint()
public CouchbaseEndpoint(String uri, String remaining, CouchbaseComponent component) throws URISyntaxException
URISyntaxException
public CouchbaseEndpoint(String endpointUri, CouchbaseComponent component)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public String getProtocol()
public void setProtocol(String protocol)
public String getBucket()
public void setBucket(String bucket)
public String getHostname()
public void setHostname(String hostname)
public int getPort()
public void setPort(int port)
public String getKey()
public void setKey(String key)
public String getUsername()
public void setUsername(String username)
public String getPassword()
public void setPassword(String password)
public String getAdditionalHosts()
public void setAdditionalHosts(String additionalHosts)
public int getPersistTo()
public void setPersistTo(int persistTo)
public int getReplicateTo()
public void setReplicateTo(int replicateTo)
public String getOperation()
public void setOperation(String operation)
public boolean isAutoStartIdForInserts()
public void setAutoStartIdForInserts(boolean autoStartIdForInserts)
public long getStartingIdForInsertsFrom()
public void setStartingIdForInsertsFrom(long startingIdForInsertsFrom)
public int getProducerRetryAttempts()
public void setProducerRetryAttempts(int producerRetryAttempts)
public int getProducerRetryPause()
public void setProducerRetryPause(int producerRetryPause)
public String getDesignDocumentName()
public void setDesignDocumentName(String designDocumentName)
public String getViewName()
public void setViewName(String viewName)
public int getLimit()
public void setLimit(int limit)
public boolean isDescending()
public void setDescending(boolean descending)
public int getSkip()
public void setSkip(int skip)
public String getRangeStartKey()
public void setRangeStartKey(String rangeStartKey)
public String getRangeEndKey()
public void setRangeEndKey(String rangeEndKey)
public String getConsumerProcessedStrategy()
public void setConsumerProcessedStrategy(String consumerProcessedStrategy)
public long getOpTimeOut()
public void setOpTimeOut(long opTimeOut)
public int getTimeoutExceptionThreshold()
public void setTimeoutExceptionThreshold(int timeoutExceptionThreshold)
public int getReadBufferSize()
public void setReadBufferSize(int readBufferSize)
public boolean isShouldOptimize()
public void setShouldOptimize(boolean shouldOptimize)
public long getMaxReconnectDelay()
public void setMaxReconnectDelay(long maxReconnectDelay)
public long getOpQueueMaxBlockTime()
public void setOpQueueMaxBlockTime(long opQueueMaxBlockTime)
public long getObsPollInterval()
public void setObsPollInterval(long obsPollInterval)
public long getObsTimeout()
public void setObsTimeout(long obsTimeout)
public URI[] makeBootstrapURI() throws URISyntaxException
URISyntaxException
Apache Camel