org.apache.camel.component.couchdb
Class CouchDbEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.couchdb.CouchDbEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class CouchDbEndpoint
extends org.apache.camel.impl.DefaultEndpoint

Field Summary

static long	DEFAULT_HEARTBEAT
static int	DEFAULT_PORT
static String	DEFAULT_STYLE

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

CouchDbEndpoint()

CouchDbEndpoint(String endpointUri, String remaining, CouchDbComponent component)

Method Summary

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)
void	setDatabase(String database)
void	setDeletes(boolean deletes)
void	setHeartbeat(long heartbeat)
void	setHostname(String hostname)
void	setPassword(String password)
void	setPort(int port)
void	setProtocol(String protocol)
void	setStyle(String style)
void	setUpdates(boolean updates)
void	setUsername(String username)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

DEFAULT_STYLE

public static final String DEFAULT_STYLE

See Also:

Constant Field Values

DEFAULT_HEARTBEAT

public static final long DEFAULT_HEARTBEAT

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

Constructor Detail

CouchDbEndpoint

public CouchDbEndpoint()

CouchDbEndpoint

public CouchDbEndpoint(String endpointUri,
                       String remaining,
                       CouchDbComponent component)
                throws Exception

Throws:

Exception

Method Detail

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

isSingleton

public boolean isSingleton()

createExchange

public org.apache.camel.Exchange createExchange(String seq,
                                                String id,
                                                com.google.gson.JsonObject obj,
                                                boolean deleted)

createClient

protected CouchDbClientWrapper createClient()

getProtocol

public String getProtocol()

setProtocol

public void setProtocol(String protocol)

getHostname

public String getHostname()

setHostname

public void setHostname(String hostname)

getStyle

public String getStyle()

setStyle

public void setStyle(String style)

getUsername

public String getUsername()

setUsername

public void setUsername(String username)

getDatabase

public String getDatabase()

setDatabase

public void setDatabase(String database)

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

getPort

public int getPort()

setPort

public void setPort(int port)

getHeartbeat

public long getHeartbeat()

setHeartbeat

public void setHeartbeat(long heartbeat)

isCreateDatabase

public boolean isCreateDatabase()

setCreateDatabase

public void setCreateDatabase(boolean createDatabase)

isDeletes

public boolean isDeletes()

setDeletes

public void setDeletes(boolean deletes)

isUpdates

public boolean isUpdates()

setUpdates

public void setUpdates(boolean updates)