@UriEndpoint(firstVersion="2.15.0", scheme="pgevent", title="PostgresSQL Event", syntax="pgevent:host:port/database/channel", consumerClass=PgEventConsumer.class, label="database,sql") public class PgEventEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
PgEventEndpoint(String uri,
PgEventComponent component) |
PgEventEndpoint(String uri,
PgEventComponent component,
DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
String |
getChannel() |
String |
getDatabase() |
DataSource |
getDatasource() |
String |
getHost() |
String |
getPass() |
Integer |
getPort() |
String |
getUser() |
com.impossibl.postgres.api.jdbc.PGConnection |
initJdbc() |
boolean |
isSingleton() |
protected void |
parseUri()
Parse the provided URI and extract available parameters
|
void |
setChannel(String channel)
The channel name
|
void |
setDatabase(String database)
The database name
|
void |
setDatasource(DataSource datasource)
To connect using the given
DataSource instead of using hostname and port. |
void |
setHost(String host)
To connect using hostname and port to the database.
|
void |
setPass(String pass)
Password for login
|
void |
setPort(Integer port)
To connect using hostname and port to the database.
|
void |
setUser(String user)
Username for login
|
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 PgEventEndpoint(String uri, PgEventComponent component)
public PgEventEndpoint(String uri, PgEventComponent component, DataSource dataSource)
public final com.impossibl.postgres.api.jdbc.PGConnection initJdbc() throws Exception
Exception
protected final void parseUri() throws IllegalArgumentException
IllegalArgumentException
- if there is an error in the parameterspublic org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public String getHost()
public void setHost(String host)
public Integer getPort()
public void setPort(Integer port)
public String getDatabase()
public void setDatabase(String database)
public String getChannel()
public void setChannel(String channel)
public String getUser()
public void setUser(String user)
public String getPass()
public void setPass(String pass)
public DataSource getDatasource()
public void setDatasource(DataSource datasource)
DataSource
instead of using hostname and port.Apache Camel