RMTxStore (Apache CXF JavaDoc 3.0.0 API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

Apache CXF API

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.cxf.ws.rm.persistence.jdbc
Class RMTxStore

java.lang.Object
  org.apache.cxf.ws.rm.persistence.jdbc.RMTxStore

All Implemented Interfaces:: RMStore

public class RMTxStore
extends Object
implements RMStore
extends Object
implements RMStore

Field Summary
`static String`	`DEFAULT_DATABASE_NAME`

Constructor Summary
`RMTxStore()`

Method Summary
`protected void`	`abort()`
`protected void`	`abort(Connection con)`
`protected void`	`beginTransaction()`
`protected void`	`cacheStatement(Connection con, String sql)`
`protected void`	`cacheStatements()`
`protected void`	`commit()` This method assumes that the connection is held and reused.
`protected void`	`commit(Connection con)`
`protected Connection`	`createConnection()`
`void`	`createDestinationSequence(DestinationSequence seq)` Create a destination sequence in the persistent store, with the sequence attributes as specified in the `RMSDestinationSequence` object.
`void`	`createSourceSequence(SourceSequence seq)` Create a source sequence in the persistent store, with the sequence attributes as specified in the `RMSourceSequence` object.
`protected void`	`createTables()`
`protected static ProtocolVariation`	`decodeProtocolVersion(String pv)`
`static void`	`deleteDatabaseFiles()`
`static void`	`deleteDatabaseFiles(String dbName, boolean now)`
`void`	`destroy()`
`protected static String`	`encodeProtocolVersion(ProtocolVariation pv)`
`DataSource`	`getDataSource()`
`DestinationSequence`	`getDestinationSequence(Identifier sid)` Retrieve the destination sequence with the specified identifier from persistent store.
`Collection<DestinationSequence>`	`getDestinationSequences(String endpointIdentifier)` Retrieves all sequences managed by the identified RM destination endpoint from persistent store.
`String`	`getDriverClassName()`
`long`	`getInitialReconnectDelay()`
`int`	`getMaxReconnectAttempts()`
`Collection<RMMessage>`	`getMessages(Identifier sid, boolean outbound)` Retrieves the outbound/inbound messages stored for the source/destination sequence with the given identifier.
`String`	`getPassword()`
`String`	`getSchemaName()`
`SourceSequence`	`getSourceSequence(Identifier sid)` Retrieve the source sequence with the specified identifier from persistent store.
`Collection<SourceSequence>`	`getSourceSequences(String endpointIdentifier)` Retrieves all sequences managed by the identified RM source endpoint from persistent store.
`protected PreparedStatement`	`getStatement(Connection con, String sql)` Returns either the locally cached statement or the one from the specified connection depending on whether the connection is held by this store.
`int`	`getTableExistsCode()`
`String`	`getTableExistsState()`
`String`	`getUrl()`
`String`	`getUserName()`
`void`	`init()`
`boolean`	`isKeepConnection()`
`protected boolean`	`isRecoverableError(SQLException ex)`
`protected boolean`	`isTableExistsError(SQLException ex)`
`void`	`persistIncoming(DestinationSequence seq, RMMessage msg)` Called by an RM source upon processing an outbound message.
`void`	`persistOutgoing(SourceSequence seq, RMMessage msg)` Called by an RM source upon processing an outbound message.
`protected void`	`releaseResources(PreparedStatement stmt, ResultSet rs)` Releases the statement and any result set.
`void`	`removeDestinationSequence(Identifier sid)` Remove the destination sequence with the specified identifier from persistent store.
`void`	`removeMessages(Identifier sid, Collection<Long> messageNrs, boolean outbound)` Removes the messages with the given message numbers and identifiers from the store of outbound/inbound messages.
`void`	`removeSourceSequence(Identifier sid)` Remove the source sequence with the specified identifier from persistent store.
`void`	`setConnection(Connection c)`
`protected void`	`setCurrentSchema()` Sets the current schema associated with the connection.
`void`	`setDataSource(DataSource ds)`
`void`	`setDriverClassName(String dcn)`
`void`	`setInitialReconnectDelay(long initialReconnectDelay)`
`void`	`setKeepConnection(boolean keepConnection)`
`void`	`setMaxReconnectAttempts(int maxReconnectAttempts)`
`void`	`setPassword(String p)`
`void`	`setSchemaName(String sn)`
`void`	`setTableExistsCode(int tableExistsCode)`
`void`	`setTableExistsState(String tableExistsState)`
`void`	`setUrl(String u)`
`void`	`setUserName(String un)`
`protected void`	`storeMessage(Connection con, Identifier sid, RMMessage msg, boolean outbound)`
`protected void`	`storeMessage(Identifier sid, RMMessage msg, boolean outbound)` this method is only useful when keepConnection is set to true
`protected void`	`updateConnectionState(Connection con, SQLException e)`
`protected void`	`updateDestinationSequence(Connection con, DestinationSequence seq)`
`protected void`	`updateDestinationSequence(DestinationSequence seq)`
`protected void`	`updateSourceSequence(Connection con, SourceSequence seq)`
`protected void`	`updateSourceSequence(SourceSequence seq)`
`protected Connection`	`verifyConnection()`
`protected void`	`verifyTable(Connection con, String tableName, String[][] tableCols)`
`protected void`	`verifyTable(String tableName, String[][] tableCols)`

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Field Detail

DEFAULT_DATABASE_NAME

public static final String DEFAULT_DATABASE_NAME

See Also:: Constant Field Values

Constructor Detail

RMTxStore

public RMTxStore()

Method Detail

destroy

public void destroy()

setDriverClassName

public void setDriverClassName(String dcn)

getDriverClassName

public String getDriverClassName()

setPassword

public void setPassword(String p)

getPassword

public String getPassword()

setUrl

public void setUrl(String u)

getUrl

public String getUrl()

setUserName

public void setUserName(String un)

getUserName

public String getUserName()

getSchemaName

public String getSchemaName()

setSchemaName

public void setSchemaName(String sn)

getDataSource

public DataSource getDataSource()

setDataSource

public void setDataSource(DataSource ds)

getTableExistsState

public String getTableExistsState()

setTableExistsState

public void setTableExistsState(String tableExistsState)

getTableExistsCode

public int getTableExistsCode()

setTableExistsCode

public void setTableExistsCode(int tableExistsCode)

isKeepConnection

public boolean isKeepConnection()

setKeepConnection

public void setKeepConnection(boolean keepConnection)

getInitialReconnectDelay

public long getInitialReconnectDelay()

setInitialReconnectDelay

public void setInitialReconnectDelay(long initialReconnectDelay)

getMaxReconnectAttempts

public int getMaxReconnectAttempts()

setMaxReconnectAttempts

public void setMaxReconnectAttempts(int maxReconnectAttempts)