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

Uses of PersistenceException in org.exolab.jms.messagemgr

Methods in org.exolab.jms.messagemgr that throw PersistenceException

boolean	ConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
boolean	ConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
boolean	ConsumerManager.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
boolean	ConsumerManager.persistentMessageRemoved(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.
boolean	DestinationCacheEventListener.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message) This event is called when a message is removed from the DestinationCache.
boolean	DestinationManager.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	DestinationManager.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
static MessageHandle	MessageHandleFactory.createPersistentHandle(java.sql.Connection connection, QueueDestinationCache queue, MessageImpl message) Create a persistent message handle belonging to a queue.
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 void	MessageHandleFactory.destroyPersistentHandle(java.sql.Connection connection, PersistentMessageHandle handle) Destroy the specified persistent handle.
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.updatePersistentHandle(java.sql.Connection connection, PersistentMessageHandle handle) Update the state of the persistent handle
protected void	MessageLeaseHelper.init(DestinationCache listener, java.sql.Connection connection) This method is used for all common initialization code.
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.
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	QueueConsumerEndpoint.persistentMessageAdded(java.sql.Connection connection, MessageImpl message)
boolean	QueueDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	QueueDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
boolean	TopicConsumerEndpoint.persistentMessageRemoved(java.sql.Connection connection, MessageImpl message)
boolean	TopicDestinationCache.persistentMessageAdded(java.sql.Connection connection, JmsDestination destination, MessageImpl message)
void	TopicDestinationCache.persistentMessageRemoved(java.sql.Connection connection, JmsDestination destination, MessageImpl message)

Constructors in org.exolab.jms.messagemgr that throw PersistenceException

MessageLeaseHelper(DestinationCache listener)
Construct a helper for the specified destination cache.

MessageLeaseHelper(java.sql.Connection connection, 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

long	BatchingRdbmsAdapter.getLastId(java.sql.Connection connection)
void	BatchingRdbmsAdapter.updateIds(java.sql.Connection connection, long id)
void	BatchingRdbmsAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
void	BatchingRdbmsAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
java.util.Vector	BatchingRdbmsAdapter.getUnprocessedMessages(java.sql.Connection connection)
void	BatchingRdbmsAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
MessageImpl	BatchingRdbmsAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
java.util.Vector	BatchingRdbmsAdapter.getMessages(java.sql.Connection connection, PersistentMessageHandle handle)
void	BatchingRdbmsAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
void	BatchingRdbmsAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
void	BatchingRdbmsAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
java.util.Vector	BatchingRdbmsAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
void	BatchingRdbmsAdapter.addDurableConsumer(java.sql.Connection connection, java.lang.String topic, java.lang.String consumer)
void	BatchingRdbmsAdapter.removeDurableConsumer(java.sql.Connection connection, java.lang.String consumer)
java.util.Enumeration	BatchingRdbmsAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
java.util.HashMap	BatchingRdbmsAdapter.getAllDurableConsumers(java.sql.Connection connection)
boolean	BatchingRdbmsAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
void	BatchingRdbmsAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
void	BatchingRdbmsAdapter.removeDestination(java.sql.Connection connection, java.lang.String name)
java.util.Enumeration	BatchingRdbmsAdapter.getAllDestinations(java.sql.Connection connection)
boolean	BatchingRdbmsAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
int	BatchingRdbmsAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String name)
int	BatchingRdbmsAdapter.getDurableConsumerMessageCount(java.sql.Connection connection, java.lang.String destination, java.lang.String name)
void	BatchingRdbmsAdapter.removeExpiredMessages(java.sql.Connection connection)
void	BatchingRdbmsAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
java.util.Vector	BatchingRdbmsAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
java.sql.Connection	BatchingRdbmsAdapter.getConnection() Return a connection to the database from the pool of connections.
void	BatchingRdbmsAdapter.addUser(java.sql.Connection connection, User user)
java.util.Enumeration	BatchingRdbmsAdapter.getAllUsers(java.sql.Connection connection)
User	BatchingRdbmsAdapter.getUser(java.sql.Connection connection, User user)
void	BatchingRdbmsAdapter.removeUser(java.sql.Connection connection, User user)
void	BatchingRdbmsAdapter.updateUser(java.sql.Connection connection, User user)
static DatabaseService	DatabaseService.instance() Return the singleton instance of the DatabaseService
static java.sql.Connection	DatabaseService.getConnection() Convenience function to return a connection to the PersistenceAdapter
void	DBConnectionManager.init() Initialise the connection manager.
java.sql.Connection	DBConnectionManager.getConnection() Retrieve a connection to the underlying database for the pool of connections.
void	DBCPConnectionManager.init() Initialise the connection manager.
java.sql.Connection	DBCPConnectionManager.getConnection() Retrieve a connection to the underlying database from the pool of connections
void	Messages.add(java.sql.Connection connection, MessageImpl message) Add a message to the database, in the context of the specified transaction and connection.
void	Messages.update(java.sql.Connection connection, MessageImpl message) Update the message state in the database.
void	Messages.remove(java.sql.Connection connection, java.lang.String messageId) Remove a message with the specified identity from the database
MessageImpl	Messages.get(java.sql.Connection connection, java.lang.String messageId) Return the message identified by the message Id
int	Messages.removeMessages(java.sql.Connection connection, java.lang.String destination) Delete all messages for the given destination
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.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.
java.util.Vector	Messages.getUnprocessedMessages(java.sql.Connection connection) Retrieve a list of unprocessed messages and return them to the client.
java.util.Vector	Messages.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination) Retrieve the message handle for all unexpired messages
void	Messages.removeExpiredMessages(java.sql.Connection connection) Delete all expired messages and associated message handles.
byte[]	Messages.serialize(MessageImpl message) Get the message as a serialized blob
MessageImpl	Messages.deserialize(byte[] blob) Set the message from a serialized blob
long	ObjectAdapter.getLastId(java.sql.Connection connection)
void	ObjectAdapter.updateIds(java.sql.Connection connection, long id)
void	ObjectAdapter.addMessage(java.sql.Connection connection, MessageImpl message)
void	ObjectAdapter.updateMessage(java.sql.Connection connection, MessageImpl message)
void	ObjectAdapter.removeMessage(java.sql.Connection connection, java.lang.String id)
MessageImpl	ObjectAdapter.getMessage(java.sql.Connection connection, java.lang.String id)
java.util.Vector	ObjectAdapter.getUnprocessedMessages(java.sql.Connection connection)
java.util.Vector	ObjectAdapter.getMessages(java.sql.Connection connection, PersistentMessageHandle handle)
void	ObjectAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
void	ObjectAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
void	ObjectAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
java.util.Vector	ObjectAdapter.getMessageHandles(java.sql.Connection connection, JmsDestination destination, java.lang.String name)
void	ObjectAdapter.addDurableConsumer(java.sql.Connection connection, java.lang.String topic, java.lang.String consumer)
void	ObjectAdapter.removeDurableConsumer(java.sql.Connection connection, java.lang.String consumer)
boolean	ObjectAdapter.durableConsumerExists(java.sql.Connection connection, java.lang.String name)
java.util.Enumeration	ObjectAdapter.getDurableConsumers(java.sql.Connection connection, java.lang.String topic)
java.util.HashMap	ObjectAdapter.getAllDurableConsumers(java.sql.Connection connection)
void	ObjectAdapter.addDestination(java.sql.Connection connection, java.lang.String name, boolean queue)
void	ObjectAdapter.removeDestination(java.sql.Connection connection, java.lang.String name)
boolean	ObjectAdapter.checkDestination(java.sql.Connection connection, java.lang.String name)
java.util.Enumeration	ObjectAdapter.getAllDestinations(java.sql.Connection connection)
int	ObjectAdapter.getQueueMessageCount(java.sql.Connection connection, java.lang.String queue)
int	ObjectAdapter.getDurableConsumerMessageCount(java.sql.Connection connection, java.lang.String topic, java.lang.String name)
void	ObjectAdapter.removeExpiredMessages(java.sql.Connection connection)
void	ObjectAdapter.removeExpiredMessageHandles(java.sql.Connection connection, java.lang.String consumer)
java.util.Vector	ObjectAdapter.getNonExpiredMessages(java.sql.Connection connection, JmsDestination destination)
void	ObjectAdapter.addUser(java.sql.Connection connection, User user)
java.util.Enumeration	ObjectAdapter.getAllUsers(java.sql.Connection connection)
User	ObjectAdapter.getUser(java.sql.Connection connection, User user)
void	ObjectAdapter.removeUser(java.sql.Connection connection, User user)
void	ObjectAdapter.updateUser(java.sql.Connection connection, User user)
java.sql.Connection	ObjectAdapter.getConnection()
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 PersistentMessageHandle 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, PersistentMessageHandle 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, PersistentMessageHandle handle) Add the specified persistent message handle.
abstract void	PersistenceAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle) Update the specified persistent message handle.
abstract void	PersistenceAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle 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, PersistentMessageHandle handle)
void	RDBMSAdapter.addMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
void	RDBMSAdapter.updateMessageHandle(java.sql.Connection connection, PersistentMessageHandle handle)
void	RDBMSAdapter.removeMessageHandle(java.sql.Connection connection, PersistentMessageHandle 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)
long	SeedGenerator.next(java.sql.Connection connection, java.lang.String name) Return the next seed value for the given name
void	SeedGenerator.removeAll(java.sql.Connection connection) Remove all seeds.

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

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	V061toV072SchemaConverter.convert()
void	V072toV076SchemaConverter.convert()