public class TransactionContext extends Object
Constructor and Description |
---|
TransactionContext(JDBCPersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
begin() |
void |
close() |
void |
commit() |
void |
executeBatch() |
PreparedStatement |
getAddMessageStatement() |
Connection |
getConnection() |
Connection |
getExclusiveConnection() |
PreparedStatement |
getRemovedMessageStatement() |
PreparedStatement |
getUpdateLastAckStatement() |
void |
onCompletion(Runnable runnable) |
void |
rollback() |
void |
setAddMessageStatement(PreparedStatement addMessageStatement) |
void |
setRemovedMessageStatement(PreparedStatement removedMessageStatement) |
void |
setTransactionIsolation(int transactionIsolation) |
void |
setUpdateLastAckStatement(PreparedStatement ackMessageStatement) |
public TransactionContext(JDBCPersistenceAdapter persistenceAdapter) throws IOException
IOException
public Connection getExclusiveConnection() throws IOException
IOException
public Connection getConnection() throws IOException
IOException
public void executeBatch() throws SQLException
SQLException
public void close() throws IOException
IOException
public void begin() throws IOException
IOException
public void commit() throws IOException
IOException
public void rollback() throws IOException
IOException
public PreparedStatement getAddMessageStatement()
public void setAddMessageStatement(PreparedStatement addMessageStatement)
public PreparedStatement getUpdateLastAckStatement()
public void setUpdateLastAckStatement(PreparedStatement ackMessageStatement)
public PreparedStatement getRemovedMessageStatement()
public void setRemovedMessageStatement(PreparedStatement removedMessageStatement)
public void setTransactionIsolation(int transactionIsolation)
public void onCompletion(Runnable runnable)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.