org.codehaus.activemq.store.jdbc
Class JDBCPersistenceAdapter
java.lang.Object
org.codehaus.activemq.service.impl.PersistenceAdapterSupport
org.codehaus.activemq.store.jdbc.JDBCPersistenceAdapter
- All Implemented Interfaces:
- org.codehaus.activemq.store.PersistenceAdapter, org.codehaus.activemq.service.Service
- public class JDBCPersistenceAdapter
- extends org.codehaus.activemq.service.impl.PersistenceAdapterSupport
A PersistenceAdapter
implementation using JDBC for
persistence storage.
- Version:
- $Revision: 1.4 $
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 |
JDBCPersistenceAdapter
public JDBCPersistenceAdapter()
JDBCPersistenceAdapter
public JDBCPersistenceAdapter(DataSource ds,
org.codehaus.activemq.io.WireFormat wireFormat)
getInitialDestinations
public Map getInitialDestinations()
createQueueMessageStore
public org.codehaus.activemq.store.MessageStore createQueueMessageStore(String destinationName)
throws JMSException
- Throws:
JMSException
createTopicMessageStore
public org.codehaus.activemq.store.TopicMessageStore createTopicMessageStore(String destinationName)
throws JMSException
- Throws:
JMSException
createPreparedTransactionStore
public org.codehaus.activemq.store.PreparedTransactionStore createPreparedTransactionStore()
throws JMSException
- Throws:
JMSException
beginTransaction
public void beginTransaction()
throws JMSException
- Throws:
JMSException
commitTransaction
public void commitTransaction()
throws JMSException
- Throws:
JMSException
rollbackTransaction
public void rollbackTransaction()
start
public void start()
throws JMSException
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Throws:
JMSException
getDataSource
public DataSource getDataSource()
setDataSource
public void setDataSource(DataSource dataSource)
getWireFormat
public org.codehaus.activemq.io.WireFormat getWireFormat()
setWireFormat
public void setWireFormat(org.codehaus.activemq.io.WireFormat wireFormat)
getConnection
public Connection getConnection()
throws SQLException
- Throws:
SQLException
returnConnection
public void returnConnection(Connection connection)
getAdapterClass
public String getAdapterClass()
- Returns:
- Returns the adapterClass.
setAdapterClass
public void setAdapterClass(String adapterClass)
- Parameters:
adapterClass
- The adapterClass to set.
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.