org.codehaus.activemq.store.jdbc
Class JDBCPersistenceAdapter

java.lang.Object
  extended byorg.codehaus.activemq.service.impl.PersistenceAdapterSupport
      extended byorg.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 $

Constructor Summary
JDBCPersistenceAdapter()
           
JDBCPersistenceAdapter(DataSource ds, org.codehaus.activemq.io.WireFormat wireFormat)
           
 
Method Summary
 void beginTransaction()
           
 void commitTransaction()
           
 org.codehaus.activemq.store.PreparedTransactionStore createPreparedTransactionStore()
           
 org.codehaus.activemq.store.MessageStore createQueueMessageStore(String destinationName)
           
 org.codehaus.activemq.store.TopicMessageStore createTopicMessageStore(String destinationName)
           
 String getAdapterClass()
           
 Connection getConnection()
           
 DataSource getDataSource()
           
 Map getInitialDestinations()
           
 org.codehaus.activemq.io.WireFormat getWireFormat()
           
 void returnConnection(Connection connection)
           
 void rollbackTransaction()
           
 void setAdapterClass(String adapterClass)
           
 void setDataSource(DataSource dataSource)
           
 void setWireFormat(org.codehaus.activemq.io.WireFormat wireFormat)
           
 void start()
           
 void stop()
           
 
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

JDBCPersistenceAdapter

public JDBCPersistenceAdapter()

JDBCPersistenceAdapter

public JDBCPersistenceAdapter(DataSource ds,
                              org.codehaus.activemq.io.WireFormat wireFormat)
Method Detail

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.