org.apache.activemq.store.jdbc
Class TransactionContext
java.lang.Object
org.apache.activemq.store.jdbc.TransactionContext
public class TransactionContext
- extends Object
Helps keep track of the current transaction/JDBC connection.
- Version:
- $Revision: 1.2 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TransactionContext
public TransactionContext(DataSource dataSource)
getConnection
public Connection getConnection()
throws IOException
- Throws:
IOException
executeBatch
public void executeBatch()
throws SQLException
- Throws:
SQLException
close
public void close()
throws IOException
- Throws:
IOException
begin
public void begin()
throws IOException
- Throws:
IOException
commit
public void commit()
throws IOException
- Throws:
IOException
rollback
public void rollback()
throws IOException
- Throws:
IOException
getAddMessageStatement
public PreparedStatement getAddMessageStatement()
setAddMessageStatement
public void setAddMessageStatement(PreparedStatement addMessageStatement)
getUpdateLastAckStatement
public PreparedStatement getUpdateLastAckStatement()
setUpdateLastAckStatement
public void setUpdateLastAckStatement(PreparedStatement ackMessageStatement)
getRemovedMessageStatement
public PreparedStatement getRemovedMessageStatement()
setRemovedMessageStatement
public void setRemovedMessageStatement(PreparedStatement removedMessageStatement)
setTransactionIsolation
public void setTransactionIsolation(int transactionIsolation)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.