org.jboss.mq.pm.jdbc2
Class MSSQLPersistenceManager

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

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 MSSQLPersistenceManager
extends PersistenceManager

MSSQLPersistenceManager.

Based on http://jira.jboss.com/jira/browse/JBAS-2369

Version:

$Revision: 57198 $

Author:

Luc Texier

Nested Class Summary

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

PersistenceManager.TransactionManagerStrategy

Field Summary

protected String

CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION

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, CREATE_TX_TABLE_XARECOVERY, createTables, datasource, DELETE_ALL_TX, DELETE_ALL_TX_XARECOVERY, DELETE_MARKED_MESSAGES, DELETE_MARKED_MESSAGES_WITH_TX, DELETE_MARKED_MESSAGES_WITH_TX_XARECOVERY, DELETE_MESSAGE, DELETE_TEMPORARY_MESSAGES, DELETE_TX, INSERT_MESSAGE, INSERT_TX, INSERT_TX_XARECOVERY, MARK_MESSAGE, nextTransactionId, OBJECT_BLOB, SELECT_ALL_TX_XARECOVERY, SELECT_MAX_TX, SELECT_MESSAGE, SELECT_MESSAGE_KEYS_IN_DEST, SELECT_MESSAGE_XARECOVERY, SELECT_MESSAGES_IN_DEST, SELECT_MESSAGES_IN_DEST_XARECOVERY, sqlProperties, tm, txManager, UPDATE_MARKED_MESSAGES, UPDATE_MARKED_MESSAGES_WITH_TX, UPDATE_MARKED_MESSAGES_XARECOVERY, UPDATE_MESSAGE, xaRecovery

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

MSSQLPersistenceManager()
Create a new MSSQLPersistenceManager.

Method Summary

protected void	createSchema()
protected void	innerCreateSchema(Connection c, PreparedStatement stmt)
void	startService()

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

add, add, addTXRecord, closeQueue, commitPersistentTx, createPersistentTx, getConnection, getConnectionManager, getConnectionRetryAttempts, getInstance, getMessageCache, getMessageCacheInstance, getRecoverMessagesChunk, getRecoveryRetries, getRecoveryTimeout, getSqlProperties, getStatementRetries, getTxManager, initializeFields, insertPersistentTx, internalRestoreQueue, isXARecovery, loadFromStorage, markMessage, remove, removeFromStorage, removeMarkedMessages, removeTXRecord, resolveAllUncommitedTXs, restoreQueue, rollbackPersistentTx, saveToStorage, setBlob, setBlob, setConnectionManager, setConnectionRetryAttempts, setMessageCache, setRecoverMessagesChunk, setRecoveryRetries, setRecoveryTimeout, setSqlProperties, setStatementRetries, setXARecovery, 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

CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION

protected String CREATE_IDX_MESSAGE_MESSAGEID_DESTINATION

Constructor Detail

MSSQLPersistenceManager

public MSSQLPersistenceManager()
                        throws javax.jms.JMSException

Create a new MSSQLPersistenceManager.

Throws:

javax.jms.JMSException - for any error

Method Detail

createSchema

protected void createSchema()
                     throws javax.jms.JMSException

Overrides:

createSchema in class PersistenceManager

Throws:

javax.jms.JMSException

innerCreateSchema

protected void innerCreateSchema(Connection c,
                                 PreparedStatement stmt)
                          throws SQLException

Throws:

SQLException

startService

public void startService()
                  throws Exception

Overrides:

startService in class PersistenceManager

Throws:

Exception