com.dsf.dbxtract.cdc

Class Config

java.lang.Object

com.dsf.dbxtract.cdc.Config

public class Config
extends java.lang.Object

The Config class represents a configuration properties file.

Expected configuration items are:

Item	Description
zookeeper	Zookeeper's connection address
thread.pool.size	Maximum concurrent data capture executors
affinity	Comma-delimited list of data sources enabled for this node
interval	Interval between data capture cycles (any integer equal to or greater than zero)
sources	Comma-delimited list of data sources
source.<source>.connection	jdbc connection string
source.<source>.driver	jdbc driver's full classname
source.<source>.user	connection's user name
source.<source>.password	user's password
source.<source>.handlers	comma-delimited list of handler's full classnames

Version:

0.5

Author:

fabio de santi

Constructor Summary

Constructors

Constructor and Description
Config(java.lang.String path) Constructs the object loading configuration properties from a given file.

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	getAffinity() Get a list of datasources enabled for this node (parameter affinity).
java.lang.String	getAgentName() Retrieves a 'unofficial' agent name based.
Sources	getDataSources() Data sources are a list of database connections and its associated handler's class names.
java.util.Collection<JournalHandler>	getHandlers() Retrieves all handlers defined in the configuration properties.
Source	getSourceByHandler(JournalHandler handler) Retrieves the data source associated to a given handler.
int	getThreadPoolSize() Retrieves the thread.pool.size parameter.
java.lang.String	getZooKeeper() Retrieves the zookeeper connection string.
void	listAll() Print out configuration data.
void	report() Nice logging for objects
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Config

public Config(java.lang.String path)
       throws ConfigurationException

Constructs the object loading configuration properties from a given file.

Parameters:

path - file/path name

Throws:

ConfigurationException - any configuration retrieval error

Method Detail

getDataSources

public Sources getDataSources()
                       throws ConfigurationException

Data sources are a list of database connections and its associated handler's class names.

Returns:

a Sources object with a list of data sources.

Throws:

ConfigurationException - when a required entry is missed

getHandlers

public java.util.Collection<JournalHandler> getHandlers()
                                                 throws ConfigurationException

Retrieves all handlers defined in the configuration properties.

Returns:

a collection of handlers

Throws:

ConfigurationException - any configuration retrieval error

getSourceByHandler

public Source getSourceByHandler(JournalHandler handler)
                          throws ConfigurationException

Retrieves the data source associated to a given handler.

Parameters:

handler - a JournalHandler object

Returns:

a Source object associated to the handler

Throws:

ConfigurationException - any configuration retrieval error

getZooKeeper

public java.lang.String getZooKeeper()
                              throws ConfigurationException

Retrieves the zookeeper connection string.

Returns:

ZooKeeper connection string (i.e. "localhost:2181")

Throws:

ConfigurationException - any configuration retrieval error

getThreadPoolSize

public int getThreadPoolSize()
                      throws ConfigurationException

Retrieves the thread.pool.size parameter.

Returns:

maximum concurrent threads

Throws:

ConfigurationException - any configuration retrieval error

getAffinity

public java.util.List<java.lang.String> getAffinity()
                                             throws ConfigurationException

Get a list of datasources enabled for this node (parameter affinity). An empty list means that all datasources must be considered.

Returns:

empty list or a list of datasources for this node

Throws:

ConfigurationException - any configuration retrieval error

getAgentName

public java.lang.String getAgentName()

Retrieves a 'unofficial' agent name based. This agent name is generated as:

• environment variable 'COMPUTERNAME' or
• environment variable 'HOSTNAME' or
• network's local hostname (Agent-xxxxx) or
• a timestamp generated when the agent is started (Agent-999999)

Returns:

a convenience name for dbxtract agent instance

report

public void report()

Nice logging for objects

listAll

public void listAll()
             throws ConfigurationException

Print out configuration data.

Throws:

ConfigurationException - any configuration retrieval error

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object