| java.lang.Object org.objectweb.celtix.bus.ws.rm.persistence.jdbc.RMTxStore
Method Summary | |
protected void | abort() | protected void | beginTransaction() | protected void | commit() | synchronized void | connect(Map<String, String> params) | public void | createDestinationSequence(RMDestinationSequence seq) | public void | createSourceSequence(RMSourceSequence seq) | protected void | createTables() | public static void | deleteDatabaseFiles(String path, boolean now) | Connection | getConnection() Accessor for connection - used in tests only. | public Collection<RMDestinationSequence> | getDestinationSequences(String endpointIdentifier) | public Collection<RMMessage> | getMessages(Identifier sid, boolean outbound) | public Collection<RMSourceSequence> | getSourceSequences(String endpointIdentifier) | public void | init(Map<String, String> params) | public void | persistIncoming(RMDestinationSequence seq, RMMessage msg) | public void | persistOutgoing(RMSourceSequence seq, RMMessage msg) | public void | removeDestinationSequence(Identifier sid) | public void | removeMessages(Identifier sid, Collection<BigInteger> messageNrs, boolean outbound) | public void | removeSourceSequence(Identifier sid) | protected void | storeMessage(Identifier sid, RMMessage msg, boolean outbound) | protected void | updateDestinationSequence(RMDestinationSequence seq) | protected void | updateSourceSequence(RMSourceSequence seq) |
CONNECTION_URL_PROPERTY | final public static String CONNECTION_URL_PROPERTY(Code) | | |
DRIVER_CLASS_NAME_PROPERTY | final public static String DRIVER_CLASS_NAME_PROPERTY(Code) | | |
PASSWORD_PROPERTY | final public static String PASSWORD_PROPERTY(Code) | | |
USER_NAME_PROPERTY | final public static String USER_NAME_PROPERTY(Code) | | |
abort | protected void abort()(Code) | | |
beginTransaction | protected void beginTransaction()(Code) | | |
deleteDatabaseFiles | public static void deleteDatabaseFiles(String path, boolean now)(Code) | | |
getConnection | Connection getConnection()(Code) | | Accessor for connection - used in tests only.
the connection |
removeDestinationSequence | public void removeDestinationSequence(Identifier sid)(Code) | | |
removeSourceSequence | public void removeSourceSequence(Identifier sid)(Code) | | |
|
|