| org.jboss.mq.pm.jdbc2.PersistenceManager org.jboss.mq.kernel.JDBC2PersistenceManager
JDBC2PersistenceManager | public class JDBC2PersistenceManager extends PersistenceManager (Code) | | lite wrapper so that this can work in a dependency injection framework.
author: Bill Burke version: $Revision: 57198 $ |
JDBC2PersistenceManager | public JDBC2PersistenceManager() throws JMSException(Code) | | |
setTransactionManager | public void setTransactionManager(TransactionManager tm)(Code) | | |
Methods inherited from org.jboss.mq.pm.jdbc2.PersistenceManager | public void add(MessageReference messageRef, Tx txId) throws javax.jms.JMSException(Code)(Java Doc) protected void add(Connection c, String queue, SpyMessage message, Tx txId, String mark) throws SQLException, IOException(Code)(Java Doc) public void addTXRecord(Connection c, Tx txid) throws SQLException, IOException(Code)(Java Doc) public void closeQueue(JMSDestination jmsDest, SpyDestination dest) throws JMSException(Code)(Java Doc) public void commitPersistentTx(Tx txId) throws javax.jms.JMSException(Code)(Java Doc) public Tx createPersistentTx() throws JMSException(Code)(Java Doc) protected synchronized void createSchema() throws JMSException(Code)(Java Doc) protected Connection getConnection() throws SQLException(Code)(Java Doc) public ObjectName getConnectionManager()(Code)(Java Doc) public int getConnectionRetryAttempts()(Code)(Java Doc) public Object getInstance()(Code)(Java Doc) public ObjectName getMessageCache()(Code)(Java Doc) public MessageCache getMessageCacheInstance()(Code)(Java Doc) public int getRecoverMessagesChunk()(Code)(Java Doc) public int getRecoveryRetries()(Code)(Java Doc) public int getRecoveryTimeout()(Code)(Java Doc) public String getSqlProperties()(Code)(Java Doc) public int getStatementRetries()(Code)(Java Doc) public TxManager getTxManager()(Code)(Java Doc) protected void initializeFields() throws MBeanException, AttributeNotFoundException, InstanceNotFoundException, ReflectionException, NamingException(Code)(Java Doc) public void insertPersistentTx(TransactionManagerStrategy tms, Connection c, Tx tx) throws JMSException(Code)(Java Doc) protected synchronized void internalRestoreQueue(JMSDestination jmsDest, SpyDestination dest) throws JMSException(Code)(Java Doc) public boolean isXARecovery()(Code)(Java Doc) public SpyMessage loadFromStorage(MessageReference messageRef) throws JMSException(Code)(Java Doc) public void markMessage(Connection c, long messageid, String destination, Tx txId, String mark) throws SQLException(Code)(Java Doc) public void remove(MessageReference messageRef, Tx txId) throws javax.jms.JMSException(Code)(Java Doc) public void removeFromStorage(MessageReference messageRef) throws JMSException(Code)(Java Doc) public void removeMarkedMessages(Connection c, Tx txid, String mark) throws SQLException(Code)(Java Doc) public void removeTXRecord(Connection c, long txid) throws SQLException(Code)(Java Doc) protected synchronized void resolveAllUncommitedTXs() throws JMSException(Code)(Java Doc) public synchronized void restoreQueue(JMSDestination jmsDest, SpyDestination dest) throws JMSException(Code)(Java Doc) public void rollbackPersistentTx(Tx txId) throws JMSException(Code)(Java Doc) public void saveToStorage(MessageReference messageRef, SpyMessage message) throws JMSException(Code)(Java Doc) public void setBlob(PreparedStatement stmt, int column, SpyMessage message) throws IOException, SQLException(Code)(Java Doc) public void setBlob(PreparedStatement stmt, int column, Xid xid) throws IOException, SQLException(Code)(Java Doc) public void setConnectionManager(ObjectName connectionManagerName)(Code)(Java Doc) public void setConnectionRetryAttempts(int value)(Code)(Java Doc) public void setMessageCache(ObjectName messageCache)(Code)(Java Doc) public void setRecoverMessagesChunk(int recoverMessagesChunk)(Code)(Java Doc) public void setRecoveryRetries(int retries)(Code)(Java Doc) public void setRecoveryTimeout(int timeout)(Code)(Java Doc) public void setSqlProperties(String value)(Code)(Java Doc) public void setStatementRetries(int statementRetries)(Code)(Java Doc) public void setXARecovery(boolean xaRecovery)(Code)(Java Doc) public void startService() throws Exception(Code)(Java Doc) public void update(MessageReference messageRef, Tx txId) throws javax.jms.JMSException(Code)(Java Doc)
|
|
|