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.
 void DestinationManagerImpl.persistentMessageAdded(JmsDestination destination, MessageImpl message)
          Invoked when the MessageManager receives a persistent message.
 void QueueDestinationCache.persistentMessageAdded(JmsDestination destination, MessageImpl message)
          Invoked when the MessageMgr receives a persistent message.
protected  void AbstractDestinationCache.persistentMessageExpired(MessageRef reference)
          Remove an expired persistent message, and notify any listeners.
protected  void QueueDestinationCache.persistentMessageExpired(MessageRef reference)
          Remove an expired persistent message, and notify any listeners.
 

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

Constructors in org.exolab.jms.persistence that throw PersistenceException
RDBMSAdapter(org.exolab.jms.config.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-2012 The OpenJMS Group. All Rights Reserved.