|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| 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. |
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||