org.jboss.messaging.core.persistence
Interface StorageManager

All Superinterfaces:
MessagingComponent
All Known Implementing Classes:
JournalStorageManager, NullStorageManager

public interface StorageManager
extends MessagingComponent

A StorageManager

Author:
Tim Fox

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 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 interface org.jboss.messaging.core.server.MessagingComponent
start, stop
 

Method Detail

generateMessageID

long generateMessageID()

generateTransactionID

long generateTransactionID()

storeMessage

void storeMessage(ServerMessage message)
                  throws java.lang.Exception
Throws:
java.lang.Exception

storeAcknowledge

void storeAcknowledge(long queueID,
                      long messageID)
                      throws java.lang.Exception
Throws:
java.lang.Exception

storeDelete

void storeDelete(long messageID)
                 throws java.lang.Exception
Throws:
java.lang.Exception

storeMessageTransactional

void storeMessageTransactional(long txID,
                               ServerMessage message)
                               throws java.lang.Exception
Throws:
java.lang.Exception

storeAcknowledgeTransactional

void storeAcknowledgeTransactional(long txID,
                                   long queueID,
                                   long messageiD)
                                   throws java.lang.Exception
Throws:
java.lang.Exception

storeDeleteTransactional

void storeDeleteTransactional(long txID,
                              long messageID)
                              throws java.lang.Exception
Throws:
java.lang.Exception

prepare

void prepare(long txID)
             throws java.lang.Exception
Throws:
java.lang.Exception

commit

void commit(long txID)
            throws java.lang.Exception
Throws:
java.lang.Exception

rollback

void rollback(long txID)
              throws java.lang.Exception
Throws:
java.lang.Exception

updateDeliveryCount

void updateDeliveryCount(MessageReference ref)
                         throws java.lang.Exception
Throws:
java.lang.Exception

loadMessages

void loadMessages(PostOffice postOffice,
                  java.util.Map<java.lang.Long,Queue> queues)
                  throws java.lang.Exception
Throws:
java.lang.Exception

addBinding

void addBinding(Binding binding)
                throws java.lang.Exception
Throws:
java.lang.Exception

deleteBinding

void deleteBinding(Binding binding)
                   throws java.lang.Exception
Throws:
java.lang.Exception

addDestination

boolean addDestination(SimpleString destination)
                       throws java.lang.Exception
Throws:
java.lang.Exception

deleteDestination

boolean deleteDestination(SimpleString destination)
                          throws java.lang.Exception
Throws:
java.lang.Exception

loadBindings

void loadBindings(QueueFactory queueFactory,
                  java.util.List<Binding> bindings,
                  java.util.List<SimpleString> destinations)
                  throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2006 JBoss Inc. All Rights Reserved.