Package org.openas2.processor.msgtracking

Class EmbeddedDBHandler

java.lang.Object

org.openas2.BaseComponent

org.openas2.processor.BaseProcessorModule

org.openas2.processor.msgtracking.BaseMsgTrackingModule

org.openas2.processor.msgtracking.DbTrackingModule

org.openas2.processor.msgtracking.EmbeddedDBHandler

All Implemented Interfaces:

Component, ActiveModule, IDBHandler, TrackingModule, ProcessorModule

class EmbeddedDBHandler
extends DbTrackingModule
implements IDBHandler

Nested Class Summary

Nested classes/interfaces inherited from class org.openas2.processor.msgtracking.BaseMsgTrackingModule

BaseMsgTrackingModule.FIELDS

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.String	connectString
private org.hsqldb.jdbc.JDBCPool	cp
private org.hsqldb.server.Server	server

Fields inherited from class org.openas2.processor.msgtracking.DbTrackingModule

dbHandler, PARAM_DB_DIRECTORY, PARAM_DB_NAME, PARAM_DB_PWD, PARAM_DB_USER, PARAM_FORCE_LOAD_JDBC_DRIVER, PARAM_JDBC_CONNECT_STRING, PARAM_JDBC_DRIVER, PARAM_JDBC_PARAMS, PARAM_JDBC_SERVER_URL, PARAM_SQL_ESCAPE_CHARACTER, PARAM_TABLE_NAME, PARAM_TCP_SERVER_PORT, PARAM_TCP_SERVER_PWD, PARAM_TCP_SERVER_START, PARAM_USE_EMBEDDED_DB

Fields inherited from interface org.openas2.processor.msgtracking.TrackingModule

DO_TRACK_MSG, TRACK_MSG_TCP_SERVER

Constructor Summary

Constructors

Constructor	Description
EmbeddedDBHandler()

Method Summary

Modifier and Type	Method	Description
void	createConnectionPool(java.lang.String connectString, java.lang.String userName, java.lang.String pwd)
void	destroyConnectionPool()
java.sql.Connection	getConnection()
boolean	shutdown(java.lang.String connectString)
void	start(java.lang.String connectString, java.lang.String userName, java.lang.String pwd, java.util.Map<java.lang.String,java.lang.String> params)
void	stop()

Methods inherited from class org.openas2.processor.msgtracking.DbTrackingModule

createParser, getModuleAction, healthcheck, init, isRunning, persist, start

Methods inherited from class org.openas2.processor.msgtracking.BaseMsgTrackingModule

buildMap, canHandle, handle

Methods inherited from class org.openas2.BaseComponent

destroy, getName, getParameter, getParameter, getParameterInt, getParameters, getSession, setParameter, setParameter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.openas2.Component

destroy, getName, getParameters, getSession

Field Detail

cp

@Nullable
private org.hsqldb.jdbc.JDBCPool cp

server

private org.hsqldb.server.Server server

connectString

private java.lang.String connectString

Constructor Detail

EmbeddedDBHandler

EmbeddedDBHandler()

Method Detail

createConnectionPool

public void createConnectionPool(java.lang.String connectString,
                                 java.lang.String userName,
                                 java.lang.String pwd)
                          throws OpenAS2Exception

Specified by:

createConnectionPool in interface IDBHandler

Throws:

OpenAS2Exception

start

public void start(java.lang.String connectString,
                  java.lang.String userName,
                  java.lang.String pwd,
                  java.util.Map<java.lang.String,java.lang.String> params)
           throws OpenAS2Exception

Specified by:

start in interface IDBHandler

Throws:

OpenAS2Exception

stop

public void stop()

Specified by:

stop in interface ActiveModule

Specified by:

stop in interface IDBHandler

Overrides:

stop in class DbTrackingModule

destroyConnectionPool

public void destroyConnectionPool()

Specified by:

destroyConnectionPool in interface IDBHandler

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException,
                                         OpenAS2Exception

Specified by:

getConnection in interface IDBHandler

Throws:

java.sql.SQLException

OpenAS2Exception

shutdown

public boolean shutdown(java.lang.String connectString)
                 throws java.sql.SQLException,
                        OpenAS2Exception

Specified by:

shutdown in interface IDBHandler

Throws:

java.sql.SQLException

OpenAS2Exception