PersistenceManager (JBoss Messaging API) - JBoss 4.0.1 sp1 messaging API Documentation 英文版文档

Overview

Package

Class

Use

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
      org.jboss.system.ServiceMBeanSupport
          org.jboss.mq.pm.jdbc3.PersistenceManager

All Implemented Interfaces:: CacheStore, CacheStoreMBean, javax.management.MBeanRegistration, NewPersistenceManager, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, PersistenceManager, PersistenceManagerMBean, PersistenceManagerMBean, Runnable, org.jboss.system.Service, org.jboss.system.ServiceMBean

public class PersistenceManager
extends org.jboss.system.ServiceMBeanSupport
implements PersistenceManagerMBean, NewPersistenceManager, CacheStore, Runnable

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

Version:: $Revision: 1.6.4.2 $
Author:: Jayesh Parayali (jayeshpk1@yahoo.com), Hiram Chirino (cojonudo14@hotmail.com), Adrian Brock (adrian@jboss.org)

Field Summary

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

PersistenceManager()
          Create a new persistence manager

Method Summary

void add(MessageReference messageRef, Tx txId)
          Add a message to the persistent store.

protected void addMessage(Connection c, String queue, SpyMessage message, Tx txId, String mark, String lateClone)
          Add a message

void addMessage(SpyMessage message)
          Persist the message

protected void addReference(Connection c, String queue, MessageReference message, Tx txId, String mark)
          Add a reference

void closeQueue(JMSDestination jmsDest, SpyDestination dest)
          Close a queue

void commitPersistentTx(Tx txId)
          Commit the transaction to the persistent store.

Tx createPersistentTx()
          Create and return a unique transaction id.

protected SpyMessage extractMessage(ResultSet rs, int column)
          Extract a message from a result

protected Connection getConnection()
          Gets a connection from the datasource, retrying as needed.

javax.management.ObjectName getConnectionManager()
          Retrieve the connection manager object name

int getConnectionRetryAttempts()
          Gets the ConnectionRetryAttempts.

int getGCPeriodSecs()
          Set the garbage collection period

Object getInstance()
          Get the persistence manager instance

javax.management.ObjectName getMessageCache()
          Unsupported operation

MessageCache getMessageCacheInstance()
          Unsupported operation

String getSqlProperties()
          Gets the sqlProperties.

TxManager getTxManager()
          Get a transaction manager.

SpyMessage loadFromStorage(MessageReference messageRef)
          Reads the message refered to by the MessagReference back as a SpyMessage

void remove(MessageReference messageRef, Tx txId)
          Remove message from the persistent store.

void removeFromStorage(MessageReference messageRef)
          Removes the message that was stored in secondary storage.

protected void removeMarkedMessages(Connection c, Tx txid, String mark)
          Remove messages for a given transaction and mark

protected void removeMarkedReferences(Connection c, Tx txid, String mark)
          Remove references for a given transaction and mark

protected void removeTXRecord(Connection c, long txid)
          Remove a transaction record

protected void resolveAllUncommitedTXs()
          Resolve uncommitted transactions

void restoreQueue(JMSDestination jmsDest, SpyDestination dest)
          Restore a queue.

void rollbackPersistentTx(Tx txId)
          Rollback the transaction.

void run()


void saveToStorage(MessageReference messageRef, SpyMessage message)
          Stores the given message to secondary storeage.

protected void setBlob(PreparedStatement stmt, int column, SpyMessage message)
          Store the message in a blob

void setConnectionManager(javax.management.ObjectName 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(javax.management.ObjectName messageCache)
          Unsupported operation

void setSqlProperties(String value)
          Sets the sqlProperties.

protected void startService()


protected void stopService()


void update(MessageReference messageRef, Tx txId)
          Update message in the persistent store.

Methods inherited from class org.jboss.system.ServiceMBeanSupport

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

addNotificationListener, getNotificationInfo, handleNotification, 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

Constructor Detail

PersistenceManager

public PersistenceManager()
                   throws javax.jms.JMSException

Create a new persistence manager
Throws:: javax.jms.JMSException - for any error

Method Detail

getConnectionManager

public javax.management.ObjectName getConnectionManager()

Retrieve the connection manager object name

Specified by:: getConnectionManager in interface PersistenceManagerMBean

setConnectionManager

public void setConnectionManager(javax.management.ObjectName connectionManagerName)

Set the connection manager object name

Specified by:: setConnectionManager in interface PersistenceManagerMBean

getGCPeriodSecs

public int getGCPeriodSecs()

Set the garbage collection period

Specified by:: getGCPeriodSecs in interface PersistenceManagerMBean

setGCPeriodSecs

public void setGCPeriodSecs(int gcPeriodSecs)

Set the garbage collection period in seconds

Specified by:: setGCPeriodSecs in interface PersistenceManagerMBean

getConnectionRetryAttempts

public int getConnectionRetryAttempts()

Gets the ConnectionRetryAttempts.

Specified by:: getConnectionRetryAttempts in interface PersistenceManagerMBean

Returns:: the number of retry events

setConnectionRetryAttempts

public void setConnectionRetryAttempts(int value)

Sets the ConnectionRetryAttempts.

Specified by:: setConnectionRetryAttempts in interface PersistenceManagerMBean

Parameters:: value - the number of retry attempts

getSqlProperties

public String getSqlProperties()

Gets the sqlProperties.

Specified by:: getSqlProperties in interface PersistenceManagerMBean

Returns:: Returns the Properties

setSqlProperties

public void setSqlProperties(String value)

Sets the sqlProperties.

Specified by:: setSqlProperties in interface PersistenceManagerMBean