@UriEndpoint(scheme="couchdb", title="CouchDB", syntax="couchdb:protocol:hostname:port/database", consumerClass=CouchDbConsumer.class, label="database,nosql") public class CouchDbEndpoint extends org.apache.camel.impl.DefaultEndpoint
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_HEARTBEAT |
static int |
DEFAULT_PORT |
static String |
DEFAULT_STYLE |
Constructor and Description |
---|
CouchDbEndpoint() |
CouchDbEndpoint(String endpointUri,
String remaining,
CouchDbComponent component) |
Modifier and Type | Method and Description |
---|---|
protected CouchDbClientWrapper |
createClient() |
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(String seq,
String id,
com.google.gson.JsonObject obj,
boolean deleted) |
org.apache.camel.Producer |
createProducer() |
String |
getDatabase() |
long |
getHeartbeat() |
String |
getHostname() |
String |
getPassword() |
int |
getPort() |
String |
getProtocol() |
String |
getStyle() |
String |
getUsername() |
boolean |
isCreateDatabase() |
boolean |
isDeletes() |
boolean |
isSingleton() |
boolean |
isUpdates() |
void |
setCreateDatabase(boolean createDatabase)
Creates the database if it does not already exist
|
void |
setDatabase(String database)
Name of the database to use
|
void |
setDeletes(boolean deletes)
Document deletes are published as events
|
void |
setHeartbeat(long heartbeat)
How often to send an empty message to keep socket alive in millis
|
void |
setHostname(String hostname)
Hostname of the running couchdb instance
|
void |
setPassword(String password)
Password for authenticated databases
|
void |
setPort(int port)
Port number for the running couchdb instance
|
void |
setProtocol(String protocol)
The protocol to use for communicating with the database.
|
void |
setStyle(String style)
Specifies how many revisions are returned in the changes array.
|
void |
setUpdates(boolean updates)
Document inserts/updates are published as events
|
void |
setUsername(String username)
Username in case of authenticated databases
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, 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 static final String DEFAULT_STYLE
public static final long DEFAULT_HEARTBEAT
public static final int DEFAULT_PORT
public CouchDbEndpoint()
public CouchDbEndpoint(String endpointUri, String remaining, CouchDbComponent component) throws Exception
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public org.apache.camel.Exchange createExchange(String seq, String id, com.google.gson.JsonObject obj, boolean deleted)
protected CouchDbClientWrapper createClient()
public String getProtocol()
public void setProtocol(String protocol)
public String getHostname()
public void setHostname(String hostname)
public String getStyle()
public void setStyle(String style)
public String getUsername()
public void setUsername(String username)
public String getDatabase()
public void setDatabase(String database)
public String getPassword()
public void setPassword(String password)
public int getPort()
public void setPort(int port)
public long getHeartbeat()
public void setHeartbeat(long heartbeat)
public boolean isCreateDatabase()
public void setCreateDatabase(boolean createDatabase)
public boolean isDeletes()
public void setDeletes(boolean deletes)
public boolean isUpdates()
public void setUpdates(boolean updates)
Apache Camel