| org.jboss.mq.pm.jdbc2.PersistenceManager
All known Subclasses: org.jboss.mq.kernel.JDBC2PersistenceManager, org.jboss.mq.pm.jdbc2.OracleThinPersistenceManager, org.jboss.mq.pm.jdbc2.MSSQLPersistenceManager,
| PersistenceManager | | public class PersistenceManager extends ServiceMBeanSupport implements PersistenceManagerMBean,org.jboss.mq.pm.PersistenceManager,CacheStore(Code) | | This class manages all persistence related services for JDBC based
persistence.
author:
Jayesh Parayali (jayeshpk1@yahoo.com)
author:
Hiram Chirino (cojonudo14@hotmail.com)
author:
Adrian Brock (adrian@jboss.com)
version:
$Revision: 61581 $ |
| Inner Class :protected class TransactionManagerStrategy | |
| Method Summary | |
| public void | add(MessageReference messageRef, Tx txId)
| | protected void | add(Connection c, String queue, SpyMessage message, Tx txId, String mark)
| | public void | addTXRecord(Connection c, Tx txid)
| | public void | closeQueue(JMSDestination jmsDest, SpyDestination dest)
| | public void | commitPersistentTx(Tx txId)
| | public Tx | createPersistentTx()
| | protected synchronized void | createSchema()
| | SpyMessage | extractMessage(ResultSet rs)
| | Xid | extractXid(ResultSet rs, int column)
| | protected Connection | getConnection()
Gets a connection from the datasource, retrying as needed. | | public ObjectName | getConnectionManager()
| | public int | getConnectionRetryAttempts()
| | public Object | getInstance()
| | public ObjectName | getMessageCache()
| | public MessageCache | getMessageCacheInstance()
| | public int | getRecoverMessagesChunk()
| | public int | getRecoveryRetries()
| | public int | getRecoveryTimeout()
| | public String | getSqlProperties()
| | public int | getStatementRetries()
| | public TxManager | getTxManager()
| | protected void | initializeFields()
| | public void | insertPersistentTx(TransactionManagerStrategy tms, Connection c, Tx tx)
| | protected synchronized void | internalRestoreQueue(JMSDestination jmsDest, SpyDestination dest)
| | public boolean | isXARecovery()
| | public SpyMessage | loadFromStorage(MessageReference messageRef)
| | public void | markMessage(Connection c, long messageid, String destination, Tx txId, String mark)
| | public void | remove(MessageReference messageRef, Tx txId)
| | public void | removeFromStorage(MessageReference messageRef)
| | public void | removeMarkedMessages(Connection c, Tx txid, String mark)
| | public void | removeTXRecord(Connection c, long txid)
| | protected synchronized void | resolveAllUncommitedTXs()
| | public synchronized void | restoreQueue(JMSDestination jmsDest, SpyDestination dest)
| | public void | rollbackPersistentTx(Tx txId)
| | public void | saveToStorage(MessageReference messageRef, SpyMessage message)
| | public void | setBlob(PreparedStatement stmt, int column, SpyMessage message)
| | public void | setBlob(PreparedStatement stmt, int column, Xid xid)
| | public void | setConnectionManager(ObjectName connectionManagerName)
| | public void | setConnectionRetryAttempts(int value)
| | public void | setMessageCache(ObjectName messageCache)
| | public void | setRecoverMessagesChunk(int recoverMessagesChunk)
| | public void | setRecoveryRetries(int retries)
| | public void | setRecoveryTimeout(int timeout)
| | public void | setSqlProperties(String value)
| | public void | setStatementRetries(int statementRetries)
| | public void | setXARecovery(boolean xaRecovery)
| | public void | startService()
| | public void | update(MessageReference messageRef, Tx txId)
|
| BINARYSTREAM_BLOB | | final protected static int BINARYSTREAM_BLOB(Code) | | |
| BLOB_BLOB | | final protected static int BLOB_BLOB(Code) | | |
| BYTES_BLOB | | final protected static int BYTES_BLOB(Code) | | |
| CREATE_IDX_MESSAGE_DESTINATION | | protected String CREATE_IDX_MESSAGE_DESTINATION(Code) | | |
| CREATE_IDX_MESSAGE_TXOP_TXID | | protected String CREATE_IDX_MESSAGE_TXOP_TXID(Code) | | |
| CREATE_MESSAGE_TABLE | | protected String CREATE_MESSAGE_TABLE(Code) | | |
| CREATE_TX_TABLE_XARECOVERY | | protected String CREATE_TX_TABLE_XARECOVERY(Code) | | |
| DELETE_ALL_TX_XARECOVERY | | protected String DELETE_ALL_TX_XARECOVERY(Code) | | |
| DELETE_MARKED_MESSAGES | | protected String DELETE_MARKED_MESSAGES(Code) | | |
| DELETE_MARKED_MESSAGES_WITH_TX | | protected String DELETE_MARKED_MESSAGES_WITH_TX(Code) | | |
| DELETE_MARKED_MESSAGES_WITH_TX_XARECOVERY | | protected String DELETE_MARKED_MESSAGES_WITH_TX_XARECOVERY(Code) | | |
| DELETE_TEMPORARY_MESSAGES | | protected String DELETE_TEMPORARY_MESSAGES(Code) | | |
| INSERT_TX_XARECOVERY | | protected String INSERT_TX_XARECOVERY(Code) | | |
| OBJECT_BLOB | | final protected static int OBJECT_BLOB(Code) | | |
| SELECT_ALL_TX_XARECOVERY | | protected String SELECT_ALL_TX_XARECOVERY(Code) | | |
| SELECT_MESSAGES_IN_DEST | | protected String SELECT_MESSAGES_IN_DEST(Code) | | |
| SELECT_MESSAGES_IN_DEST_XARECOVERY | | protected String SELECT_MESSAGES_IN_DEST_XARECOVERY(Code) | | |
| SELECT_MESSAGE_KEYS_IN_DEST | | protected String SELECT_MESSAGE_KEYS_IN_DEST(Code) | | |
| SELECT_MESSAGE_XARECOVERY | | protected String SELECT_MESSAGE_XARECOVERY(Code) | | |
| UPDATE_MARKED_MESSAGES | | protected String UPDATE_MARKED_MESSAGES(Code) | | |
| UPDATE_MARKED_MESSAGES_WITH_TX | | protected String UPDATE_MARKED_MESSAGES_WITH_TX(Code) | | |
| UPDATE_MARKED_MESSAGES_XARECOVERY | | protected String UPDATE_MARKED_MESSAGES_XARECOVERY(Code) | | |
| blobType | | protected int blobType(Code) | | |
| connectionManagerName | | protected ObjectName connectionManagerName(Code) | | The object name of the DataSource
|
| connectionRetryAttempts | | protected int connectionRetryAttempts(Code) | | |
| createTables | | protected boolean createTables(Code) | | |
| nextTransactionId | | protected SynchronizedLong nextTransactionId(Code) | | The next transaction id
|
| tm | | protected TransactionManager tm(Code) | | The JBossMQ transaction mananger
|
| xaRecovery | | protected boolean xaRecovery(Code) | | |
| PersistenceManager | | public PersistenceManager() throws javax.jms.JMSException(Code) | | |
| commitPersistentTx | | public void commitPersistentTx(Tx txId) throws javax.jms.JMSException(Code) | | |
| createPersistentTx | | public Tx createPersistentTx() throws JMSException(Code) | | |
| createSchema | | protected synchronized void createSchema() throws JMSException(Code) | | |
| getConnection | | protected Connection getConnection() throws SQLException(Code) | | Gets a connection from the datasource, retrying as needed. This was
implemented because in some minimal configurations (i.e. little logging
and few services) the database wasn't ready when we tried to get a
connection. We, therefore, implement a retry loop wich is controled
by the ConnectionRetryAttempts attribute. Submitted by terry@amicas.com
the connection
exception:
SQLException - if an error occurs. |
| getConnectionRetryAttempts | | public int getConnectionRetryAttempts()(Code) | | |
| getRecoverMessagesChunk | | public int getRecoverMessagesChunk()(Code) | | |
| getRecoveryRetries | | public int getRecoveryRetries()(Code) | | |
| getRecoveryTimeout | | public int getRecoveryTimeout()(Code) | | |
| getStatementRetries | | public int getStatementRetries()(Code) | | |
| insertPersistentTx | | public void insertPersistentTx(TransactionManagerStrategy tms, Connection c, Tx tx) throws JMSException(Code) | | |
| isXARecovery | | public boolean isXARecovery()(Code) | | |
| resolveAllUncommitedTXs | | protected synchronized void resolveAllUncommitedTXs() throws JMSException(Code) | | |
| rollbackPersistentTx | | public void rollbackPersistentTx(Tx txId) throws JMSException(Code) | | |
| setConnectionManager | | public void setConnectionManager(ObjectName connectionManagerName)(Code) | | |
| setConnectionRetryAttempts | | public void setConnectionRetryAttempts(int value)(Code) | | |
| setRecoverMessagesChunk | | public void setRecoverMessagesChunk(int recoverMessagesChunk)(Code) | | |
| setRecoveryRetries | | public void setRecoveryRetries(int retries)(Code) | | |
| setRecoveryTimeout | | public void setRecoveryTimeout(int timeout)(Code) | | |
| setSqlProperties | | public void setSqlProperties(String value)(Code) | | |
| setStatementRetries | | public void setStatementRetries(int statementRetries)(Code) | | |
| setXARecovery | | public void setXARecovery(boolean xaRecovery)(Code) | | |
|
|