org.apache.camel.component.pgevent

Class PgEventEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.component.pgevent.PgEventEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId, StatefulService, SuspendableService

@UriEndpoint(scheme="pgevent",
             title="PostgresSQL Event",
             syntax="pgevent:host:port/database/channel",
             consumerClass=PgEventConsumer.class,
             label="database,sql")
public class PgEventEndpoint
extends DefaultEndpoint

The pgevent component allows for producing/consuming PostgreSQL events related to the LISTEN/NOTIFY commands. This requires using PostgreSQL 8.3 or newer.

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
PgEventEndpoint(String uri, PgEventComponent component)
PgEventEndpoint(String uri, PgEventComponent component, DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
String	getChannel()
String	getDatabase()
DataSource	getDatasource()
String	getHost()
String	getPass()
Integer	getPort()
String	getUser()
com.impossibl.postgres.api.jdbc.PGConnection	initJdbc()
boolean	isSingleton() Whether this class supports being singleton or not.
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

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, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, 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, isSuspendingOrSuspended, 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

Constructor Detail

PgEventEndpoint

public PgEventEndpoint(String uri,
                       PgEventComponent component)

PgEventEndpoint

public PgEventEndpoint(String uri,
                       PgEventComponent component,
                       DataSource dataSource)

Method Detail

initJdbc

public final com.impossibl.postgres.api.jdbc.PGConnection initJdbc()
                                                            throws Exception

Throws:

Exception

parseUri

protected final void parseUri()
                       throws IllegalArgumentException

Parse the provided URI and extract available parameters

Throws:

IllegalArgumentException - if there is an error in the parameters

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

isSingleton

public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Returns:

true to be a single shared instance, false to create new instances.

getHost

public String getHost()

setHost

public void setHost(String host)

To connect using hostname and port to the database.

getPort

public Integer getPort()

setPort

public void setPort(Integer port)

To connect using hostname and port to the database.

getDatabase

public String getDatabase()

setDatabase

public void setDatabase(String database)

The database name

getChannel

public String getChannel()

setChannel

public void setChannel(String channel)

The channel name

getUser

public String getUser()

setUser

public void setUser(String user)

Username for login

getPass

public String getPass()

setPass

public void setPass(String pass)

Password for login

getDatasource

public DataSource getDatasource()

setDatasource

public void setDatasource(DataSource datasource)

To connect using the given DataSource instead of using hostname and port.