org.apache.activemq.store.jdbc
public class TransactionContext extends java.lang.Object
Constructor and Description |
---|
TransactionContext(JDBCPersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
begin() |
void |
close() |
void |
commit() |
void |
executeBatch() |
java.sql.PreparedStatement |
getAddMessageStatement() |
java.sql.Connection |
getConnection() |
java.sql.PreparedStatement |
getRemovedMessageStatement() |
java.sql.PreparedStatement |
getUpdateLastAckStatement() |
void |
rollback() |
void |
setAddMessageStatement(java.sql.PreparedStatement addMessageStatement) |
void |
setRemovedMessageStatement(java.sql.PreparedStatement removedMessageStatement) |
void |
setTransactionIsolation(int transactionIsolation) |
void |
setUpdateLastAckStatement(java.sql.PreparedStatement ackMessageStatement) |
public TransactionContext(JDBCPersistenceAdapter persistenceAdapter) throws java.io.IOException
java.io.IOException
public java.sql.Connection getConnection() throws java.io.IOException
java.io.IOException
public void executeBatch() throws java.sql.SQLException
java.sql.SQLException
public void close() throws java.io.IOException
java.io.IOException
public void begin() throws java.io.IOException
java.io.IOException
public void commit() throws java.io.IOException
java.io.IOException
public void rollback() throws java.io.IOException
java.io.IOException
public java.sql.PreparedStatement getAddMessageStatement()
public void setAddMessageStatement(java.sql.PreparedStatement addMessageStatement)
public java.sql.PreparedStatement getUpdateLastAckStatement()
public void setUpdateLastAckStatement(java.sql.PreparedStatement ackMessageStatement)
public java.sql.PreparedStatement getRemovedMessageStatement()
public void setRemovedMessageStatement(java.sql.PreparedStatement removedMessageStatement)
public void setTransactionIsolation(int transactionIsolation)
Copyright © 2005-2014. All Rights Reserved.