Uses of Class
org.exolab.jms.persistence.PersistenceException

Packages that use PersistenceException
org.exolab.jms.messagemgr   
org.exolab.jms.persistence   
 

Uses of PersistenceException in org.exolab.jms.messagemgr
 

Methods in org.exolab.jms.messagemgr that throw PersistenceException
 void MessageManagerEventListener.persistentMessageAdded(JmsDestination destination, MessageImpl message)
          Invoked when the MessageManager receives a persistent message.
protected  void AbstractDestinationCache.persistentMessageExpired(MessageRef reference)
          Remove an expired persistent message, and notify any listeners.
 void QueueDestinationCache.persistentMessageAdded(JmsDestination destination, MessageImpl message)
          Invoked when the MessageMgr receives a persistent message.
protected  void QueueDestinationCache.persistentMessageExpired(MessageRef reference)
          Remove an expired persistent message, and notify any listeners.
 void DestinationManagerImpl.persistentMessageAdded(JmsDestination destination, MessageImpl message)
          Invoked when the MessageManager receives a persistent message.
 

Constructors in org.exolab.jms.messagemgr that throw PersistenceException
DurableConsumerEndpoint(long consumerId, JmsTopic topic, java.lang.String name, DestinationManager destinations)
          Construct a new DurableConsumerEndpoint.
 

Uses of PersistenceException in org.exolab.jms.persistence
 

Methods in org.exolab.jms.persistence that throw PersistenceException
static DatabaseService DatabaseService.getInstance()
          Returns the database service associated with the current thread.
 void DatabaseService.begin()
          Begin a transaction.
 java.sql.Connection DatabaseService.getConnection()
          Returns the connection associated with the current thread.
 void DatabaseService.commit()
          Commit the current transaction.
 void DatabaseService.rollback()
          Rollback the current transaction.
 void DBCPConnectionManager.init()
          Initialise the connection manager.
 java.sql.Connection DBCPConnectionManager.getConnection()
          Retrieve a connection to the underlying database from the pool of connections.
abstract  long PersistenceAdapter.getLastId(java.sql.Connection connection)
          Check to see if the root is created.
abstract  void PersistenceAdapter.updateIds(java.sql.Connection connection, long id)
          Update the given id.
abstract  void PersistenceAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
          Add a new message to the database.
abstract  void PersistenceAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
          Update this message in the database
abstract  void PersistenceAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
          Remove the message with the specified identity from the database
abstract  void PersistenceAdapter.removeExpiredMessages(java.sql.Connection connection)
          Remove all expired messages and associated references from the database.
abstract  void PersistenceAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
          Remove all expired messages handles associated with this durable consumer.
abstract  java.util.Vector PersistenceAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
          Retrieve a list of unexpired MessageHandle objects, for the specified destination.
abstract  MessageImpl PersistenceAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
          Get a message from the persistence store.
abstract  java.util.Vector PersistenceAdapter.getMessages(java.sql.Connection connection, MessageHandle handle)
          Get at least the next message given the specified persistent handle.
abstract  java.util.Vector PersistenceAdapter.getUnprocessedMessages(java.sql.Connection connection)
          Return a list of unprocessed messages.
abstract  void PersistenceAdapter.addMessageHandle(java.sql.Connection connection, MessageHandle handle)
          Add the specified persistent message handle.
abstract  void PersistenceAdapter.updateMessageHandle(java.sql.Connection connection, MessageHandle handle)
          Update the specified persistent message handle.
abstract  void PersistenceAdapter.removeMessageHandle(java.sql.Connection connection, MessageHandle handle)
          Remove the specified persistent message handle.
abstract  java.util.Vector PersistenceAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
          Get all the persistent message handles for the specified destination and consumer name.
abstract  void PersistenceAdapter.addDurableConsumer(java.sql.Connection connection, java.lang.String topic, java.lang.String consumer)
          Add the specified durable consumer
abstract  void PersistenceAdapter.removeDurableConsumer(java.sql.Connection connection, java.lang.String consumer)
          Remove the durable consumer for the specified topic.
abstract  boolean PersistenceAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
          Check if the durable consumer exists
abstract  java.util.Enumeration PersistenceAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
          Get an enumerated list of all durable consumers for the specified JmsTopic destination
abstract  java.util.HashMap PersistenceAdapter.getAllDurableConsumers(java.sql.Connection connection)
          Return a dictionary of all registered durable consumers.
abstract  void PersistenceAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
          Add a new destination to the database.
abstract  void PersistenceAdapter.removeDestination(java.sql.Connection connection, java.lang.String destination)
          Remove the destination with the specified name and all registered consumers from the database.
abstract  boolean PersistenceAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
          Determine if a particular destination name exists
abstract  java.util.Enumeration PersistenceAdapter.getAllDestinations(java.sql.Connection connection)
          Get a list of all destinations stored in the database
abstract  int PersistenceAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String name)
          Get the number of unsent messages for a the specified queue
abstract  int PersistenceAdapter.getDurableConsumerMessageCount(java.sql.Connection connection, java.lang.String destination, java.lang.String name)
          Return the number of unsent message for the specified durable consumer.
abstract  java.sql.Connection PersistenceAdapter.getConnection()
          Return a connection to this persistent data store.
abstract  java.util.Enumeration PersistenceAdapter.getAllUsers(java.sql.Connection connection)
           
abstract  void PersistenceAdapter.addUser(java.sql.Connection connection, User user)
           
abstract  void PersistenceAdapter.removeUser(java.sql.Connection connection, User user)
           
abstract  void PersistenceAdapter.updateUser(java.sql.Connection connection, User user)
           
abstract  User PersistenceAdapter.getUser(java.sql.Connection connection, User user)
           
 long RDBMSAdapter.getLastId(java.sql.Connection connection)
           
 void RDBMSAdapter.updateIds(java.sql.Connection connection, long id)
           
 void RDBMSAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
 void RDBMSAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
 java.util.Vector RDBMSAdapter.getUnprocessedMessages(java.sql.Connection connection)
           
 void RDBMSAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
           
 MessageImpl RDBMSAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
           
 java.util.Vector RDBMSAdapter.getMessages(java.sql.Connection connection, MessageHandle handle)
           
 void RDBMSAdapter.addMessageHandle(java.sql.Connection connection, MessageHandle handle)
           
 void RDBMSAdapter.updateMessageHandle(java.sql.Connection connection, MessageHandle handle)
           
 void RDBMSAdapter.removeMessageHandle(java.sql.Connection connection, MessageHandle handle)
           
 java.util.Vector RDBMSAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
           
 void RDBMSAdapter.addDurableConsumer(java.sql.Connection connection, java.lang.String topic, java.lang.String consumer)
           
 void RDBMSAdapter.removeDurableConsumer(java.sql.Connection connection, java.lang.String consumer)
           
 java.util.Enumeration RDBMSAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
           
 java.util.HashMap RDBMSAdapter.getAllDurableConsumers(java.sql.Connection connection)
           
 boolean RDBMSAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
           
 void RDBMSAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
           
 void RDBMSAdapter.removeDestination(java.sql.Connection connection, java.lang.String name)
           
 java.util.Enumeration RDBMSAdapter.getAllDestinations(java.sql.Connection connection)
           
 boolean RDBMSAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
           
 int RDBMSAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String name)
           
 int RDBMSAdapter.getDurableConsumerMessageCount(java.sql.Connection connection, java.lang.String destination, java.lang.String name)
           
 void RDBMSAdapter.removeExpiredMessages(java.sql.Connection connection)
           
 void RDBMSAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
           
 java.util.Vector RDBMSAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
           
 java.sql.Connection RDBMSAdapter.getConnection()
          Return a connection to the database from the pool of connections.
 void RDBMSAdapter.addUser(java.sql.Connection connection, User user)
           
 java.util.Enumeration RDBMSAdapter.getAllUsers(java.sql.Connection connection)
           
 User RDBMSAdapter.getUser(java.sql.Connection connection, User user)
           
 void RDBMSAdapter.removeUser(java.sql.Connection connection, User user)
           
 void RDBMSAdapter.updateUser(java.sql.Connection connection, User user)
           
 void DBConnectionManager.init()
          Initialise the connection manager.
 java.sql.Connection DBConnectionManager.getConnection()
          Retrieve a connection to the underlying database for the pool of connections.
 

Constructors in org.exolab.jms.persistence that throw PersistenceException
RDBMSAdapter(DatabaseConfiguration dbConfig, java.lang.String driver, java.lang.String url, java.lang.String userName, java.lang.String password)
          Connects to the given db.
 



Copyright © 1999-2007 The OpenJMS Group. All Rights Reserved.