MessageLog (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.file
Class MessageLog

java.lang.Object
  org.jboss.mq.pm.file.MessageLog

public class MessageLog
extends Object

This is used to keep SpyMessages on the disk and is used reconstruct the queue in case of provider failure.

Version:: $Revision: 1.14.2.2 $

Constructor Summary

MessageLog(MessageCache messageCache, File file)


Method Summary

void add(MessageReference messageRef, Tx transactionId)


void close()


protected void delete(File file)


void finishAdd(MessageReference message, Tx transactionId)


void finishRemove(MessageReference messageRef, Tx transactionId)


void finishUpdate(MessageReference messageRef, Tx transactionId)


void remove(SpyMessage message, Tx transactionId)


protected void rename(File from, File to)


Map restore(TreeSet rollBackTXs)


protected void restoreMessageFromFile(TreeMap store, File file)


void undoAdd(MessageReference messageRef, Tx transactionId)


void undoRemove(MessageReference message, Tx transactionId)


void update(MessageReference messageRef, Tx transactionId)


protected void writeMessageToFile(SpyMessage message, File file)


Methods inherited from class java.lang.Object

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

Constructor Detail

MessageLog

public MessageLog(MessageCache messageCache,
                  File file)
           throws javax.jms.JMSException

Method Detail

close

public void close()
           throws javax.jms.JMSException

Throws:: javax.jms.JMSException

restore

public Map restore(TreeSet rollBackTXs)
            throws javax.jms.JMSException

Throws:: javax.jms.JMSException

add

public void add(MessageReference messageRef,
                Tx transactionId)
         throws javax.jms.JMSException

Throws:: javax.jms.JMSException

finishAdd

public void finishAdd(MessageReference message,
                      Tx transactionId)
               throws javax.jms.JMSException

Throws:: javax.jms.JMSException

finishRemove

public void finishRemove(MessageReference messageRef,
                         Tx transactionId)
                  throws javax.jms.JMSException

Throws:: javax.jms.JMSException

remove

public void remove(SpyMessage message,
                   Tx transactionId)
            throws javax.jms.JMSException

Throws:: javax.jms.JMSException

update

public void update(MessageReference messageRef,
                   Tx transactionId)
            throws javax.jms.JMSException

Throws:: javax.jms.JMSException

finishUpdate

public void finishUpdate(MessageReference messageRef,
                         Tx transactionId)
                  throws javax.jms.JMSException

Throws:: javax.jms.JMSException

undoAdd

public void undoAdd(MessageReference messageRef,
                    Tx transactionId)
             throws javax.jms.JMSException

Throws:: javax.jms.JMSException

undoRemove

public void undoRemove(MessageReference message,
                       Tx transactionId)
                throws javax.jms.JMSException

Throws:: javax.jms.JMSException

delete

protected void delete(File file)
               throws IOException

Throws:: IOException

rename

protected void rename(File from,
                      File to)
               throws IOException

Throws:: IOException

writeMessageToFile

protected void writeMessageToFile(SpyMessage message,
                                  File file)
                           throws IOException

Throws:: IOException

restoreMessageFromFile

protected void restoreMessageFromFile(TreeMap store,
                                      File file)
                               throws Exception

Throws:: Exception