|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.impl.PersistenceAdapterSupport
org.codehaus.activemq.store.jdbc.JDBCPersistenceAdapter
A PersistenceAdapter
implementation using JDBC for
persistence storage.
Constructor Summary | |
JDBCPersistenceAdapter()
|
|
JDBCPersistenceAdapter(DataSource ds,
WireFormat wireFormat)
|
Method Summary | |
void |
beginTransaction()
This method starts a transaction on the persistent storage - which is nothing to do with JMS or XA transactions - its purely a mechanism to perform multiple writes to a persistent store in 1 transaction as a performance optimisation. |
void |
commitTransaction()
Commit a persistence transaction |
PreparedTransactionStore |
createPreparedTransactionStore()
Factory method to create a new persistent prepared transaction store for XA recovery |
MessageStore |
createQueueMessageStore(String destinationName)
Factory method to create a new queue message store with the given destination name |
TopicMessageStore |
createTopicMessageStore(String destinationName)
Factory method to create a new topic message store with the given destination name |
Connection |
getConnection()
|
DataSource |
getDataSource()
|
Map |
getInitialDestinations()
Returns a map, indexed by String name, of all the Destination
objects active on startup. |
WireFormat |
getWireFormat()
|
void |
returnConnection(Connection connection)
|
void |
rollbackTransaction()
Rollback a persistence transaction |
void |
setDataSource(DataSource dataSource)
|
void |
setWireFormat(WireFormat wireFormat)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class org.codehaus.activemq.service.impl.PersistenceAdapterSupport |
createQueueMessageContainer, createTopicMessageContainer |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public JDBCPersistenceAdapter()
public JDBCPersistenceAdapter(DataSource ds, WireFormat wireFormat)
Method Detail |
public Map getInitialDestinations()
PersistenceAdapter
Destination
objects active on startup.
public MessageStore createQueueMessageStore(String destinationName) throws JMSException
PersistenceAdapter
JMSException
public TopicMessageStore createTopicMessageStore(String destinationName) throws JMSException
PersistenceAdapter
JMSException
public PreparedTransactionStore createPreparedTransactionStore() throws JMSException
PersistenceAdapter
JMSException
public void beginTransaction() throws JMSException
PersistenceAdapter
JMSException
public void commitTransaction() throws JMSException
PersistenceAdapter
JMSException
PersistenceAdapter.beginTransaction()
public void rollbackTransaction()
PersistenceAdapter
PersistenceAdapter.beginTransaction()
public void start() throws JMSException
Service
JMSException
public void stop() throws JMSException
Service
JMSException
public DataSource getDataSource()
public void setDataSource(DataSource dataSource)
public WireFormat getWireFormat()
public void setWireFormat(WireFormat wireFormat)
public Connection getConnection() throws SQLException
SQLException
public void returnConnection(Connection connection)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |