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

Packages that use PersistenceException
org.exolab.jms.messagemgr   
org.exolab.jms.persistence   
org.exolab.jms.tools.db   
org.exolab.jms.tools.db.migration   
 

Uses of PersistenceException in org.exolab.jms.messagemgr
 

Methods in org.exolab.jms.messagemgr that throw PersistenceException
static MessageHandle MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, DurableConsumerEndpoint durable, MessageImpl message)
          Create a persistent handle for a message belonging to a particular durable consumer
static MessageHandle MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, JmsDestination dest, java.lang.String name, MessageImpl message)
          Create a persistent message handle from the destination and consumer name
static MessageHandle MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, QueueDestinationCache queue, MessageImpl message)
          Create a persistent message handle belonging to a queue.
static void MessageHandleFactory.destroyPersistentHandle(java.sql.Connection connection, JmsDestination destination, java.lang.String name, MessageImpl message)
          Destroy a persistent handle associated with a destination, consumer name and message
static void MessageHandleFactory.destroyPersistentHandle(java.sql.Connection connection, PersistentMessageHandle handle)
          Destroy the specified persistent handle.
protected  void MessageLeaseHelper.init(DestinationCache listener, java.sql.Connection connection)
          This method is used for all common initialization code.
 boolean DestinationManager.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 boolean QueueDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 boolean TopicDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 boolean MessageManagerEventListener.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
          This event is called when the MessageMgr adds a persistent message to the cache.
 boolean ConsumerManager.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
           
 boolean ConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
           
 boolean QueueConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
           
 boolean DestinationCacheEventListener.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
          This event is called when a persistent message is added to the DestinationCache.
 void DestinationManager.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 void QueueDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 void TopicDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
           
 void MessageManagerEventListener.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
          This event is called when the MessageMgr removes a persistent message from the cache.
 boolean ConsumerManager.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
           
 boolean TopicConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
           
 boolean ConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
           
 boolean DestinationCacheEventListener.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
          This event is called when a message is removed from the DestinationCache.
static void MessageHandleFactory.updatePersistentHandle(java.sql.Connection connection, PersistentMessageHandle handle)
          Update the state of the persistent handle
 

Constructors in org.exolab.jms.messagemgr that throw PersistenceException
MessageLeaseHelper(java.sql.Connection connection, DestinationCache listener)
          Construct a helper for the specified destination cache.
MessageLeaseHelper(DestinationCache listener)
          Construct a helper for the specified destination cache.
 

Uses of PersistenceException in org.exolab.jms.persistence
 

Methods in org.exolab.jms.persistence that throw PersistenceException
 void Messages.add(java.sql.Connection connection, MessageImpl message)
          Add a message to the database, in the context of the specified transaction and connection.
abstract  void PersistenceAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
          Add a new destination to the database.
 void ObjectAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
           
 void BatchingRdbmsAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
           
 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 ObjectAdapter.addDurableConsumer(java.sql.Connection connection, java.lang.String topic, java.lang.String consumer)
           
 void BatchingRdbmsAdapter.addDurableConsumer(java.sql.Connection connection, java.lang.String topic, java.lang.String 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 ObjectAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
 void BatchingRdbmsAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
 void RDBMSAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
           
abstract  void PersistenceAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
          Add the specified persistent message handle.
 void ObjectAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 void BatchingRdbmsAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 void RDBMSAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
abstract  void PersistenceAdapter.addUser(java.sql.Connection connection, User user)
           
 void ObjectAdapter.addUser(java.sql.Connection connection, User user)
           
 void BatchingRdbmsAdapter.addUser(java.sql.Connection connection, User user)
           
 void RDBMSAdapter.addUser(java.sql.Connection connection, User user)
           
abstract  boolean PersistenceAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
          Determine if a particular destination name exists
 boolean ObjectAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
           
 boolean BatchingRdbmsAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
           
 boolean RDBMSAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
           
 MessageImpl Messages.deserialize(byte[] blob)
          Set the message from a serialized blob
abstract  boolean PersistenceAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
          Check if the durable consumer exists
 boolean ObjectAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
           
 boolean BatchingRdbmsAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
           
 boolean RDBMSAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
           
 MessageImpl Messages.get(java.sql.Connection connection, java.lang.String messageId)
          Return the message identified by the message Id
abstract  java.util.Enumeration PersistenceAdapter.getAllDestinations(java.sql.Connection connection)
          Get a list of all destinations stored in the database
 java.util.Enumeration ObjectAdapter.getAllDestinations(java.sql.Connection connection)
           
 java.util.Enumeration BatchingRdbmsAdapter.getAllDestinations(java.sql.Connection connection)
           
 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 ObjectAdapter.getAllDurableConsumers(java.sql.Connection connection)
           
 java.util.HashMap BatchingRdbmsAdapter.getAllDurableConsumers(java.sql.Connection connection)
           
 java.util.HashMap RDBMSAdapter.getAllDurableConsumers(java.sql.Connection connection)
           
abstract  java.util.Enumeration PersistenceAdapter.getAllUsers(java.sql.Connection connection)
           
 java.util.Enumeration ObjectAdapter.getAllUsers(java.sql.Connection connection)
           
 java.util.Enumeration BatchingRdbmsAdapter.getAllUsers(java.sql.Connection connection)
           
 java.util.Enumeration RDBMSAdapter.getAllUsers(java.sql.Connection connection)
           
static java.sql.Connection DatabaseService.getConnection()
          Convenience function to return a connection to the PersistenceAdapter
abstract  java.sql.Connection PersistenceAdapter.getConnection()
          Return a connection to this persistent data store.
 java.sql.Connection ObjectAdapter.getConnection()
           
 java.sql.Connection DBCPConnectionManager.getConnection()
          Retrieve a connection to the underlying database from the pool of connections
 java.sql.Connection BatchingRdbmsAdapter.getConnection()
          Return a connection to the database from the pool of connections.
 java.sql.Connection RDBMSAdapter.getConnection()
          Return a connection to the database from the pool of connections.
 java.sql.Connection DBConnectionManager.getConnection()
          Retrieve a connection to the underlying database for 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 ObjectAdapter.getDurableConsumerMessageCount(java.sql.Connection connection, java.lang.String topic, java.lang.String name)
           
 int BatchingRdbmsAdapter.getDurableConsumerMessageCount(java.sql.Connection connection, java.lang.String destination, java.lang.String name)
           
 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 ObjectAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
           
 java.util.Enumeration BatchingRdbmsAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
           
 java.util.Enumeration RDBMSAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
           
abstract  long PersistenceAdapter.getLastId(java.sql.Connection connection)
          Check to see if the root is created.
 long ObjectAdapter.getLastId(java.sql.Connection connection)
           
 long BatchingRdbmsAdapter.getLastId(java.sql.Connection connection)
           
 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 ObjectAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
           
 MessageImpl BatchingRdbmsAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
           
 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 ObjectAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
           
 java.util.Vector BatchingRdbmsAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
           
 java.util.Vector RDBMSAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
           
 java.util.HashMap Messages.getMessageIds(java.sql.Connection connection, long time, int hint)
          Retrieve the specified number of message ids from the database with a time greater than that specified.
abstract  java.util.Vector PersistenceAdapter.getMessages(java.sql.Connection connection, PersistentMessageHandle handle)
          Get at least the next message given the specified persistent handle.
 java.util.Vector ObjectAdapter.getMessages(java.sql.Connection connection, PersistentMessageHandle handle)
           
 java.util.Vector BatchingRdbmsAdapter.getMessages(java.sql.Connection connection, PersistentMessageHandle handle)
           
 java.util.Vector RDBMSAdapter.getMessages(java.sql.Connection connection, PersistentMessageHandle handle)
           
 java.util.Vector Messages.getMessages(java.sql.Connection connection, java.lang.String destination, int priority, long time)
          Retrieve the next set of messages for the specified destination with an acceptance time greater or equal to that specified.
 java.util.Vector Messages.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
          Retrieve the message handle for all unexpired messages
abstract  java.util.Vector PersistenceAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
          Retrieve a list of unexpired PersistentMessageHandle objects, for the specified destination.
 java.util.Vector ObjectAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
           
 java.util.Vector BatchingRdbmsAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination 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 ObjectAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String queue)
           
 int BatchingRdbmsAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String name)
           
 int RDBMSAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String name)
           
 java.util.Vector Messages.getUnprocessedMessages(java.sql.Connection connection)
          Retrieve a list of unprocessed messages and return them to the client.
abstract  java.util.Vector PersistenceAdapter.getUnprocessedMessages(java.sql.Connection connection)
          Return a list of unprocessed messages.
 java.util.Vector ObjectAdapter.getUnprocessedMessages(java.sql.Connection connection)
           
 java.util.Vector BatchingRdbmsAdapter.getUnprocessedMessages(java.sql.Connection connection)
           
 java.util.Vector RDBMSAdapter.getUnprocessedMessages(java.sql.Connection connection)
           
abstract  User PersistenceAdapter.getUser(java.sql.Connection connection, User user)
           
 User ObjectAdapter.getUser(java.sql.Connection connection, User user)
           
 User BatchingRdbmsAdapter.getUser(java.sql.Connection connection, User user)
           
 User RDBMSAdapter.getUser(java.sql.Connection connection, User user)
           
 void DBCPConnectionManager.init()
          Initialise the connection manager.
 void DBConnectionManager.init()
          Initialise the connection manager.
static DatabaseService DatabaseService.instance()
          Return the singleton instance of the DatabaseService
 long SeedGenerator.next(java.sql.Connection connection, java.lang.String name)
          Return the next seed value for the given name
 void Messages.remove(java.sql.Connection connection, java.lang.String messageId)
          Remove a message with the specified identity from the database
 void SeedGenerator.removeAll(java.sql.Connection connection)
          Remove all seeds.
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 ObjectAdapter.removeDestination(java.sql.Connection connection, java.lang.String name)
           
 void BatchingRdbmsAdapter.removeDestination(java.sql.Connection connection, java.lang.String name)
           
 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 ObjectAdapter.removeDurableConsumer(java.sql.Connection connection, java.lang.String consumer)
           
 void BatchingRdbmsAdapter.removeDurableConsumer(java.sql.Connection connection, java.lang.String consumer)
           
 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 ObjectAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
           
 void BatchingRdbmsAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
           
 void RDBMSAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
           
 void Messages.removeExpiredMessages(java.sql.Connection connection)
          Delete all expired messages and associated message handles.
abstract  void PersistenceAdapter.removeExpiredMessages(java.sql.Connection connection)
          Remove all expired messages and associated references from the database.
 void ObjectAdapter.removeExpiredMessages(java.sql.Connection connection)
           
 void BatchingRdbmsAdapter.removeExpiredMessages(java.sql.Connection connection)
           
 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 ObjectAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
           
 void BatchingRdbmsAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
           
 void RDBMSAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
           
abstract  void PersistenceAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
          Remove the specified persistent message handle.
 void ObjectAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 void BatchingRdbmsAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 void RDBMSAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 int Messages.removeMessages(java.sql.Connection connection, java.lang.String destination)
          Delete all messages for the given destination
abstract  void PersistenceAdapter.removeUser(java.sql.Connection connection, User user)
           
 void ObjectAdapter.removeUser(java.sql.Connection connection, User user)
           
 void BatchingRdbmsAdapter.removeUser(java.sql.Connection connection, User user)
           
 void RDBMSAdapter.removeUser(java.sql.Connection connection, User user)
           
 byte[] Messages.serialize(MessageImpl message)
          Get the message as a serialized blob
 void Messages.update(java.sql.Connection connection, MessageImpl message)
          Update the message state in the database.
abstract  void PersistenceAdapter.updateIds(java.sql.Connection connection, long id)
          Update the given id.
 void ObjectAdapter.updateIds(java.sql.Connection connection, long id)
           
 void BatchingRdbmsAdapter.updateIds(java.sql.Connection connection, long 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 ObjectAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
 void BatchingRdbmsAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
 void RDBMSAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
           
abstract  void PersistenceAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
          Update the specified persistent message handle.
 void ObjectAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 void BatchingRdbmsAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
 void RDBMSAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
           
abstract  void PersistenceAdapter.updateUser(java.sql.Connection connection, User user)
           
 void ObjectAdapter.updateUser(java.sql.Connection connection, User user)
           
 void BatchingRdbmsAdapter.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
ObjectAdapter(java.lang.String dbName, int minListSize, int minMsgSize, int minCacheSize)
          Constructs a databse with the given name, if one does not exist, otherwise opens the existing database.
 

Uses of PersistenceException in org.exolab.jms.tools.db
 

Subclasses of PersistenceException in org.exolab.jms.tools.db
 class InvalidTypeException
          This exception is thrown when a JDBC type is encountered which is not supported by the target database
 

Methods in org.exolab.jms.tools.db that throw PersistenceException
 void SchemaConverter.convert()
           
 void DBTool.create()
          Creates the database tables using the default schema
 void RDBMSTool.create(Database schema)
          Creates the database
 void DBTool.create(java.lang.String path)
          Creates the database tables from the specified schema
 void RDBMSTool.create(Table table)
          Creates a table in the database
 void DBTool.drop()
          Drop the database tables from the default schema
 void RDBMSTool.drop(Database schema)
          Drops tables from the database
 void DBTool.drop(java.lang.String path)
          Drop the database tables from the specified schema
 void RDBMSTool.drop(Table table)
          Drops a table from the database.
static Database SchemaHelper.getSchema()
           
static Database SchemaHelper.getSchema(java.lang.String path)
           
static Database SchemaHelper.getSchemaFromResource(java.lang.String path)
           
static java.lang.String SchemaHelper.getSchemaVersion(java.sql.Connection connection)
          Get the schema version
 Table SchemaBrowser.getTable(java.lang.String name)
          Returns the schema for the specified table
 boolean SchemaBrowser.getTableExists(java.lang.String table)
          Returns true if a table exists
 Type SchemaBrowser.getType(Attribute attribute)
          Returns the Type for an Attribute
static Type Type.getType(java.lang.String type)
          Returns a new type corresponding to its string representation
 void DBTool.migrate()
          Migrates the database tables to the latest version
static void SchemaHelper.setVersion(java.sql.Connection connection, java.lang.String version)
           
 

Constructors in org.exolab.jms.tools.db that throw PersistenceException
DBTool(java.lang.String path)
          Construct an instance with the path to an openjms XML configuration file
RDBMSTool(java.sql.Connection connection)
          Construct a new RDBMSTool
SchemaBrowser(java.sql.Connection connection)
          Construct a new SchemaBrowser
 

Uses of PersistenceException in org.exolab.jms.tools.db.migration
 

Methods in org.exolab.jms.tools.db.migration that throw PersistenceException
 void V072toV076SchemaConverter.convert()
           
 void V061toV072SchemaConverter.convert()
           
 



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