PersistenceManager

Overview

Package

Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.pm.jdbc3
Class PersistenceManager

java.lang.Object
  org.jboss.mx.util.JBossNotificationBroadcasterSupport (src) 
      org.jboss.system.ServiceMBeanSupport (src) 
          org.jboss.mq.pm.jdbc3.PersistenceManager

All Implemented Interfaces:: CacheStore (src) , MBeanRegistration (src) , NewPersistenceManager (src) , NotificationBroadcaster (src) , NotificationEmitter (src) , PersistenceManager (src) , java.lang.Runnable, Service (src) , ServiceMBean (src)

public class PersistenceManager
extends ServiceMBeanSupport (src)
implements NewPersistenceManager (src) , CacheStore (src) , java.lang.Runnable

This class manages all persistence related services for JDBC based persistence.

Field Summary

Fields inherited from class org.jboss.system.ServiceMBeanSupport (src)

log, server, SERVICE_CONTROLLER_SIG, serviceName

Fields inherited from interface org.jboss.system.ServiceMBean (src)

CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED

Constructor Summary
`PersistenceManager()` Create a new persistence manager

Method Summary
`void`	`add(MessageReference (src) messageRef, Tx (src) txId)` Add a message to the persistent store.
`protected void`	`addMessage(java.sql.Connection c, java.lang.String queue, SpyMessage (src) message, Tx (src) txId, java.lang.String mark, java.lang.String lateClone)` Add a message
`void`	`addMessage(SpyMessage (src) message)` Persist the message
`protected void`	`addReference(java.sql.Connection c, java.lang.String queue, MessageReference (src) message, Tx (src) txId, java.lang.String mark)` Add a reference
`void`	`closeQueue(JMSDestination (src) jmsDest, SpyDestination (src) dest)` Close a queue
`void`	`commitPersistentTx(Tx (src) txId)` Commit the transaction to the persistent store.
`Tx (src)`	`createPersistentTx()` Create and return a unique transaction id.
`protected SpyMessage (src)`	`extractMessage(java.sql.ResultSet rs, int column)` Extract a message from a result
`protected java.sql.Connection`	`getConnection()` Gets a connection from the datasource, retrying as needed.
`ObjectName (src)`	`getConnectionManager()` Retrieve the connection manager object name
`int`	`getConnectionRetryAttempts()` Gets the ConnectionRetryAttempts.
`int`	`getGCPeriodSecs()` Set the garbage collection period
`java.lang.Object`	`getInstance()`
`ObjectName (src)`	`getMessageCache()` Unsupported operation
`MessageCache (src)`	`getMessageCacheInstance()` Unsupported operation
`java.lang.String`	`getSqlProperties()` Gets the sqlProperties.
`TxManager (src)`	`getTxManager()` Get a transaction manager.
`SpyMessage (src)`	`loadFromStorage(MessageReference (src) messageRef)` Reads the message refered to by the MessagReference back as a SpyMessage
`void`	`remove(MessageReference (src) messageRef, Tx (src) txId)` Remove message from the persistent store.
`void`	`removeFromStorage(MessageReference (src) messageRef)` Removes the message that was stored in secondary storage.
`protected void`	`removeMarkedMessages(java.sql.Connection c, Tx (src) txid, java.lang.String mark)` Remove messages for a given transaction and mark
`protected void`	`removeMarkedReferences(java.sql.Connection c, Tx (src) txid, java.lang.String mark)` Remove references for a given transaction and mark
`protected void`	`removeTXRecord(java.sql.Connection c, long txid)` Remove a transaction record
`protected void`	`resolveAllUncommitedTXs()` Resolve uncommitted transactions
`void`	`restoreQueue(JMSDestination (src) jmsDest, SpyDestination (src) dest)` Restore a queue.
`void`	`rollbackPersistentTx(Tx (src) txId)` Rollback the transaction.
`void`	`run()`
`void`	`saveToStorage(MessageReference (src) messageRef, SpyMessage (src) message)` Stores the given message to secondary storeage.
`protected void`	`setBlob(java.sql.PreparedStatement stmt, int column, SpyMessage (src) message)` Store the message in a blob
`void`	`setConnectionManager(ObjectName (src) connectionManagerName)` Set the connection manager object name
`void`	`setConnectionRetryAttempts(int value)` Sets the ConnectionRetryAttempts.
`void`	`setGCPeriodSecs(int gcPeriodSecs)` Set the garbage collection period in seconds
`void`	`setMessageCache(ObjectName (src) messageCache)` Unsupported operation
`void`	`setSqlProperties(java.lang.String value)` Sets the sqlProperties.
`protected void`	`startService()` Sub-classes should override this method to provide custum 'start' logic.
`protected void`	`stopService()` Sub-classes should override this method to provide custum 'stop' logic.
`void`	`update(MessageReference (src) messageRef, Tx (src) txId)` Update message in the persistent store.

Methods inherited from class org.jboss.system.ServiceMBeanSupport (src)

create, createService, destroy, destroyService, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop

Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport (src)

addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistenceManager

public PersistenceManager()
                   throws JMSException (src)

Create a new persistence manager
Throws:: JMSException (src) - for any error

Method Detail

getConnectionManager

public ObjectName (src)  getConnectionManager()

Retrieve the connection manager object name

setConnectionManager

public void setConnectionManager(ObjectName (src)  connectionManagerName)

Set the connection manager object name

getGCPeriodSecs

public int getGCPeriodSecs()

Set the garbage collection period

setGCPeriodSecs

public void setGCPeriodSecs(int gcPeriodSecs)

Set the garbage collection period in seconds

getConnectionRetryAttempts

public int getConnectionRetryAttempts()

Gets the ConnectionRetryAttempts.

Returns:: the number of retry events

setConnectionRetryAttempts

public void setConnectionRetryAttempts(int value)

Sets the ConnectionRetryAttempts.

Parameters:: value - the number of retry attempts

getSqlProperties

public java.lang.String getSqlProperties()

Gets the sqlProperties.

Returns:: Returns the Properties

setSqlProperties

public void setSqlProperties(java.lang.String value)

Sets the sqlProperties.