org.activemq.store.jdbc
Class JDBCPersistenceAdapter

java.lang.Object
  extended byorg.activemq.store.jdbc.JDBCPersistenceAdapter
All Implemented Interfaces:
PersistenceAdapter, Service

public class JDBCPersistenceAdapter
extends java.lang.Object
implements PersistenceAdapter

A PersistenceAdapter implementation using JDBC for persistence storage. This persistence adapter will correctly remember prepared XA transactions, but it will not keep track of local transaction commits so that operations performed against the Message store are done as a single uow.

Version:
$Revision: 1.1 $

Constructor Summary
JDBCPersistenceAdapter()
           
JDBCPersistenceAdapter(javax.sql.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 cleanup()
           
 void commitTransaction()
          Commit a persistence transaction
 MessageStore createQueueMessageStore(java.lang.String destinationName)
          Factory method to create a new queue message store with the given destination name
 TopicMessageStore createTopicMessageStore(java.lang.String destinationName)
          Factory method to create a new topic message store with the given destination name
 TransactionStore createTransactionStore()
          Factory method to create a new persistent prepared transaction store for XA recovery
 java.lang.String getAdapterClass()
           
 int getCleanupPeriod()
           
 EDU.oswego.cs.dl.util.concurrent.ClockDaemon getClockDaemon()
           
 java.sql.Connection getConnection()
           
 javax.sql.DataSource getDataSource()
           
 boolean getDropTablesOnStartup()
           
 java.util.Map getInitialDestinations()
          Returns a map, indexed by String name, of all the Destination objects active on startup.
 WireFormat getWireFormat()
           
 void returnConnection(java.sql.Connection connection)
           
 void rollbackTransaction()
          Rollback a persistence transaction
 void setAdapterClass(java.lang.String adapterClass)
           
 void setCleanupPeriod(int cleanupPeriod)
           
 void setClockDaemon(EDU.oswego.cs.dl.util.concurrent.ClockDaemon clockDaemon)
           
 void setDataSource(javax.sql.DataSource dataSource)
           
 void setDropTablesOnStartup(boolean dropTablesOnStartup)
           
 void setWireFormat(WireFormat wireFormat)
           
 void start()
          Called to start the service
 void stop()
          Called to shutdown the service
 
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(javax.sql.DataSource ds,
                              WireFormat wireFormat)
Method Detail

getInitialDestinations

public java.util.Map getInitialDestinations()
Description copied from interface: PersistenceAdapter
Returns a map, indexed by String name, of all the Destination objects active on startup.

Specified by:
getInitialDestinations in interface PersistenceAdapter
Returns:

createQueueMessageStore

public MessageStore createQueueMessageStore(java.lang.String destinationName)
                                     throws javax.jms.JMSException
Description copied from interface: PersistenceAdapter
Factory method to create a new queue message store with the given destination name

Specified by:
createQueueMessageStore in interface PersistenceAdapter
Throws:
javax.jms.JMSException

createTopicMessageStore

public TopicMessageStore createTopicMessageStore(java.lang.String destinationName)
                                          throws javax.jms.JMSException
Description copied from interface: PersistenceAdapter
Factory method to create a new topic message store with the given destination name

Specified by:
createTopicMessageStore in interface PersistenceAdapter
Throws:
javax.jms.JMSException

createTransactionStore

public TransactionStore createTransactionStore()
                                        throws javax.jms.JMSException
Description copied from interface: PersistenceAdapter
Factory method to create a new persistent prepared transaction store for XA recovery

Specified by:
createTransactionStore in interface PersistenceAdapter
Throws:
javax.jms.JMSException

beginTransaction

public void beginTransaction()
                      throws javax.jms.JMSException
Description copied from interface: PersistenceAdapter
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.

Typically one transaction will require one disk synchronization point and so for real high performance its usually faster to perform many writes within the same transaction to minimise latency caused by disk synchronization. This is especially true when using tools like Berkeley Db or embedded JDBC servers.

Specified by:
beginTransaction in interface PersistenceAdapter
Throws:
javax.jms.JMSException

commitTransaction

public void commitTransaction()
                       throws javax.jms.JMSException
Description copied from interface: PersistenceAdapter
Commit a persistence transaction

Specified by:
commitTransaction in interface PersistenceAdapter
Throws:
javax.jms.JMSException
See Also:
PersistenceAdapter.beginTransaction()

rollbackTransaction

public void rollbackTransaction()
Description copied from interface: PersistenceAdapter
Rollback a persistence transaction

Specified by:
rollbackTransaction in interface PersistenceAdapter
See Also:
PersistenceAdapter.beginTransaction()

start

public void start()
           throws javax.jms.JMSException
Description copied from interface: Service
Called to start the service

Specified by:
start in interface Service
Throws:
javax.jms.JMSException

cleanup

public void cleanup()

setClockDaemon

public void setClockDaemon(EDU.oswego.cs.dl.util.concurrent.ClockDaemon clockDaemon)

getClockDaemon

public EDU.oswego.cs.dl.util.concurrent.ClockDaemon getClockDaemon()

stop

public void stop()
          throws javax.jms.JMSException
Description copied from interface: Service
Called to shutdown the service

Specified by:
stop in interface Service
Throws:
javax.jms.JMSException

getDataSource

public javax.sql.DataSource getDataSource()

setDataSource

public void setDataSource(javax.sql.DataSource dataSource)

getWireFormat

public WireFormat getWireFormat()

setWireFormat

public void setWireFormat(WireFormat wireFormat)

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException
Throws:
java.sql.SQLException

returnConnection

public void returnConnection(java.sql.Connection connection)

getAdapterClass

public java.lang.String getAdapterClass()
Returns:
Returns the adapterClass.

setAdapterClass

public void setAdapterClass(java.lang.String adapterClass)
Parameters:
adapterClass - The adapterClass to set.

getDropTablesOnStartup

public boolean getDropTablesOnStartup()
Returns:
Returns the dropTablesOnStartup.

setDropTablesOnStartup

public void setDropTablesOnStartup(boolean dropTablesOnStartup)
Parameters:
dropTablesOnStartup - The dropTablesOnStartup to set.

getCleanupPeriod

public int getCleanupPeriod()

setCleanupPeriod

public void setCleanupPeriod(int cleanupPeriod)


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.