org.jboss.messaging.core.persistence.impl.journal
Class JournalStorageManager

java.lang.Object
  extended by org.jboss.messaging.core.persistence.impl.journal.JournalStorageManager
All Implemented Interfaces:
StorageManager, MessagingComponent

public class JournalStorageManager
extends java.lang.Object
implements StorageManager

A JournalStorageManager

Author:
Tim Fox, Clebert Suconic

Field Summary
static byte ACKNOWLEDGE_REF
           
static byte ADD_MESSAGE
           
static byte SET_SCHEDULED_DELIVERY_TIME
           
static int SIZE_FIELDS
           
static byte UPDATE_DELIVERY_COUNT
           
 
Constructor Summary
JournalStorageManager(Configuration config)
           
 
Method Summary
 void addBinding(Binding binding)
           
 boolean addDestination(SimpleString destination)
           
 void commit(long txID)
           
 void deleteBinding(Binding binding)
           
 boolean deleteDestination(SimpleString destination)
           
 long generateMessageID()
           
 long generateTransactionID()
           
 void loadBindings(QueueFactory queueFactory, java.util.List<Binding> bindings, java.util.List<SimpleString> destinations)
           
 void loadMessages(PostOffice postOffice, java.util.Map<java.lang.Long,Queue> queues)
           
 void prepare(long txID)
           
 void rollback(long txID)
           
 void start()
           
 void stop()
           
 void storeAcknowledge(long queueID, long messageID)
           
 void storeAcknowledgeTransactional(long txID, long queueID, long messageID)
           
 void storeDelete(long messageID)
           
 void storeDeleteTransactional(long txID, long messageID)
           
 void storeMessage(ServerMessage message)
           
 void storeMessageTransactional(long txID, ServerMessage message)
           
 void updateDeliveryCount(MessageReference ref)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

SIZE_FIELDS

public static final int SIZE_FIELDS
See Also:
Constant Field Values

ADD_MESSAGE

public static final byte ADD_MESSAGE
See Also:
Constant Field Values

ACKNOWLEDGE_REF

public static final byte ACKNOWLEDGE_REF
See Also:
Constant Field Values

UPDATE_DELIVERY_COUNT

public static final byte UPDATE_DELIVERY_COUNT
See Also:
Constant Field Values

SET_SCHEDULED_DELIVERY_TIME

public static final byte SET_SCHEDULED_DELIVERY_TIME
See Also:
Constant Field Values
Constructor Detail

JournalStorageManager

public JournalStorageManager(Configuration config)
Method Detail

generateMessageID

public long generateMessageID()
Specified by:
generateMessageID in interface StorageManager

generateTransactionID

public long generateTransactionID()
Specified by:
generateTransactionID in interface StorageManager

storeMessage

public void storeMessage(ServerMessage message)
                  throws java.lang.Exception
Specified by:
storeMessage in interface StorageManager
Throws:
java.lang.Exception

storeAcknowledge

public void storeAcknowledge(long queueID,
                             long messageID)
                      throws java.lang.Exception
Specified by:
storeAcknowledge in interface StorageManager
Throws:
java.lang.Exception

storeDelete

public void storeDelete(long messageID)
                 throws java.lang.Exception
Specified by:
storeDelete in interface StorageManager
Throws:
java.lang.Exception

storeMessageTransactional

public void storeMessageTransactional(long txID,
                                      ServerMessage message)
                               throws java.lang.Exception
Specified by:
storeMessageTransactional in interface StorageManager
Throws:
java.lang.Exception

storeAcknowledgeTransactional

public void storeAcknowledgeTransactional(long txID,
                                          long queueID,
                                          long messageID)
                                   throws java.lang.Exception
Specified by:
storeAcknowledgeTransactional in interface StorageManager
Throws:
java.lang.Exception

storeDeleteTransactional

public void storeDeleteTransactional(long txID,
                                     long messageID)
                              throws java.lang.Exception
Specified by:
storeDeleteTransactional in interface StorageManager
Throws:
java.lang.Exception

prepare

public void prepare(long txID)
             throws java.lang.Exception
Specified by:
prepare in interface StorageManager
Throws:
java.lang.Exception

commit

public void commit(long txID)
            throws java.lang.Exception
Specified by:
commit in interface StorageManager
Throws:
java.lang.Exception

rollback

public void rollback(long txID)
              throws java.lang.Exception
Specified by:
rollback in interface StorageManager
Throws:
java.lang.Exception

updateDeliveryCount

public void updateDeliveryCount(MessageReference ref)
                         throws java.lang.Exception
Specified by:
updateDeliveryCount in interface StorageManager
Throws:
java.lang.Exception

loadMessages

public void loadMessages(PostOffice postOffice,
                         java.util.Map<java.lang.Long,Queue> queues)
                  throws java.lang.Exception
Specified by:
loadMessages in interface StorageManager
Throws:
java.lang.Exception

addBinding

public void addBinding(Binding binding)
                throws java.lang.Exception
Specified by:
addBinding in interface StorageManager
Throws:
java.lang.Exception

deleteBinding

public void deleteBinding(Binding binding)
                   throws java.lang.Exception
Specified by:
deleteBinding in interface StorageManager
Throws:
java.lang.Exception

addDestination

public boolean addDestination(SimpleString destination)
                       throws java.lang.Exception
Specified by:
addDestination in interface StorageManager
Throws:
java.lang.Exception

deleteDestination

public boolean deleteDestination(SimpleString destination)
                          throws java.lang.Exception
Specified by:
deleteDestination in interface StorageManager
Throws:
java.lang.Exception

loadBindings

public void loadBindings(QueueFactory queueFactory,
                         java.util.List<Binding> bindings,
                         java.util.List<SimpleString> destinations)
                  throws java.lang.Exception
Specified by:
loadBindings in interface StorageManager
Throws:
java.lang.Exception

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface MessagingComponent
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface MessagingComponent
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.