org.jboss.mq.pm.jdbc2
Class OracleThinPersistenceManager

java.lang.Object
  org.jboss.mx.util.JBossNotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
          org.jboss.mq.pm.jdbc2.PersistenceManager
              org.jboss.mq.pm.jdbc2.OracleThinPersistenceManager

All Implemented Interfaces:

javax.management.MBeanRegistration, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, CacheStore, CacheStoreMBean, PersistenceManager, PersistenceManagerMBean, org.jboss.system.Service, org.jboss.system.ServiceMBean

public class OracleThinPersistenceManager
extends PersistenceManager

OracleThinPersistenceManager.

Based on information provided by Ron Teeter at TradeBeam Holdings, Inc.

Version:

$Revision: 1.1.2.2 $

Author:

Adrian Brock

Nested Class Summary

Nested classes/interfaces inherited from class org.jboss.mq.pm.jdbc2.PersistenceManager

PersistenceManager.TransactionManagerStrategy

Field Summary

protected String	INSERT_EMPTY_BLOB Insert an empty blob
protected String	LOCK_EMPTY_BLOB Lock empty blob

Fields inherited from class org.jboss.mq.pm.jdbc2.PersistenceManager

BINARYSTREAM_BLOB, BLOB_BLOB, blobType, BYTES_BLOB, connectionManagerName, connectionRetryAttempts, CREATE_IDX_MESSAGE_DESTINATION, CREATE_IDX_MESSAGE_TXOP_TXID, CREATE_MESSAGE_TABLE, CREATE_TX_TABLE, createTables, datasource, DELETE_ALL_TX, DELETE_MARKED_MESSAGES, DELETE_MARKED_MESSAGES_WITH_TX, DELETE_MESSAGE, DELETE_TEMPORARY_MESSAGES, DELETE_TX, INSERT_MESSAGE, INSERT_TX, MARK_MESSAGE, nextTransactionId, OBJECT_BLOB, SELECT_MAX_TX, SELECT_MESSAGE, SELECT_MESSAGE_KEYS_IN_DEST, SELECT_MESSAGES_IN_DEST, sqlProperties, tm, txManager, UPDATE_MARKED_MESSAGES, UPDATE_MARKED_MESSAGES_WITH_TX, UPDATE_MESSAGE

Fields inherited from class org.jboss.system.ServiceMBeanSupport

log, server, SERVICE_CONTROLLER_SIG, serviceName

Fields inherited from interface org.jboss.system.ServiceMBean

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

Fields inherited from interface org.jboss.mq.pm.PersistenceManagerMBean

OBJECT_NAME

Constructor Summary

OracleThinPersistenceManager()
Create a new OracleThinPersistenceManager.

Method Summary

protected void	add(Connection c, String queue, SpyMessage message, Tx txId, String mark)
protected void	safeClose(PreparedStatement stmt, ResultSet rs)
void	startService()

Methods inherited from class org.jboss.mq.pm.jdbc2.PersistenceManager

add, addTXRecord, closeQueue, commitPersistentTx, createPersistentTx, createSchema, getConnection, getConnectionManager, getConnectionRetryAttempts, getInstance, getMessageCache, getMessageCacheInstance, getRecoverMessagesChunk, getRecoveryRetries, getRecoveryTimeout, getSqlProperties, getTxManager, initializeFields, insertPersistentTx, internalRestoreQueue, loadFromStorage, markMessage, remove, removeFromStorage, removeMarkedMessages, removeTXRecord, resolveAllUncommitedTXs, restoreQueue, rollbackPersistentTx, saveToStorage, setBlob, setConnectionManager, setConnectionRetryAttempts, setMessageCache, setRecoverMessagesChunk, setRecoveryRetries, setRecoveryTimeout, setSqlProperties, update

Methods inherited from class org.jboss.system.ServiceMBeanSupport

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

Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, nextNotificationSequenceNumber, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString, jbossInternalLifecycle

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Field Detail

INSERT_EMPTY_BLOB

protected String INSERT_EMPTY_BLOB

Insert an empty blob

LOCK_EMPTY_BLOB

protected String LOCK_EMPTY_BLOB

Lock empty blob

Constructor Detail

OracleThinPersistenceManager

public OracleThinPersistenceManager()
                             throws javax.jms.JMSException

Create a new OracleThinPersistenceManager.

Throws:

javax.jms.JMSException - for any error

Method Detail

add

protected void add(Connection c,
                   String queue,
                   SpyMessage message,
                   Tx txId,
                   String mark)
            throws SQLException,
                   IOException

Overrides:

add in class PersistenceManager

Throws:

SQLException

IOException

startService

public void startService()
                  throws Exception

Overrides:

startService in class PersistenceManager

Throws:

Exception

safeClose

protected void safeClose(PreparedStatement stmt,
                         ResultSet rs)