PersistenceManager (JBoss Messaging API) - JBoss 3.2.7 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
Interface PersistenceManager

All Known Subinterfaces:: NewPersistenceManager

All Known Implementing Classes:: NewPersistenceManager, PersistenceManager, PersistenceManager, PersistenceManager, PersistenceManager, PersistenceManager

public interface PersistenceManager

This class allows provides the base for user supplied persistence packages.

Version:: $Revision: 1.7.2.2 $
Author:: Hiram Chirino (Cojonudo14@hotmail.com), Paul Kendall (paul.kendall@orion.co.nz), Adrian Brock

Method Summary

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

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.

MessageCache getMessageCacheInstance()
          Get the message cache

TxManager getTxManager()
          Get a transaction manager.

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

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

void rollbackPersistentTx(Tx txId)
          Rollback the transaction.

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

Method Detail

getMessageCacheInstance

public MessageCache getMessageCacheInstance()

Get the message cache

Returns:: the instance of the message cache

createPersistentTx

public Tx createPersistentTx()
                      throws javax.jms.JMSException

Create and return a unique transaction id.

Returns:: the transaction
Throws:: javax.jms.JMSException - for any error

commitPersistentTx

public void commitPersistentTx(Tx txId)
                        throws javax.jms.JMSException

Commit the transaction to the persistent store.

Parameters:: txId - Description of Parameter
Throws:: javax.jms.JMSException - for any error

rollbackPersistentTx

public void rollbackPersistentTx(Tx txId)
                          throws javax.jms.JMSException

Rollback the transaction.

Parameters:: txId - Description of Parameter
Throws:: javax.jms.JMSException - for any error

getTxManager

public TxManager getTxManager()

Get a transaction manager.

Returns:: the transaction manager
Throws:: javax.jms.JMSException - for any error

add

public void add(MessageReference message,
                Tx txId)
         throws javax.jms.JMSException

Add a message to the persistent store. If the message is part of a transaction, txId is not null.

Parameters:: message - the message; txId - the transaction
Throws:: javax.jms.JMSException - for any error

restoreQueue

public void restoreQueue(JMSDestination jmsDest,
                         SpyDestination dest)
                  throws javax.jms.JMSException

Restore a queue.

Parameters:: jmsDest - the jms destination; dest - the client destination
Throws:: javax.jms.JMSException - for any error

update

public void update(MessageReference message,
                   Tx txId)
            throws javax.jms.JMSException

Update message in the persistent store. If the message is part of a transaction, txId is not null (not currently supported).

Parameters:: message -; txId - Description of Parameter
Throws:: javax.jms.JMSException - for any error

remove

public void remove(MessageReference message,
                   Tx txId)
            throws javax.jms.JMSException

Remove message from the persistent store. If the message is part of a transaction, txId is not null.

Parameters:: message - the message; txId - the transaction
Throws:: javax.jms.JMSException - for any error

closeQueue

public void closeQueue(JMSDestination jmsDest,
                       SpyDestination dest)
                throws javax.jms.JMSException

Close a queue

Parameters:: jmsDest - the jms destination; dest - the client destination
Throws:: javax.jms.JMSException - for any error