org.jboss.messaging.core.persistence.impl.nullpm
Class NullStorageManager

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

public class NullStorageManager
extends java.lang.Object
implements StorageManager

A NullStorageManager

Author:
Andy Taylor, Tim Fox

Constructor Summary
NullStorageManager()
           
 
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
 

Constructor Detail

NullStorageManager

public NullStorageManager()
Method Detail

addBinding

public void addBinding(Binding binding)
                throws java.lang.Exception
Specified by:
addBinding 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

commit

public void commit(long txID)
            throws java.lang.Exception
Specified by:
commit 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

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

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

prepare

public void prepare(long txID)
             throws java.lang.Exception
Specified by:
prepare 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

storeAcknowledge

public void storeAcknowledge(long queueID,
                             long messageID)
                      throws java.lang.Exception
Specified by:
storeAcknowledge 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

storeDelete

public void storeDelete(long messageID)
                 throws java.lang.Exception
Specified by:
storeDelete 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

storeMessage

public void storeMessage(ServerMessage message)
                  throws java.lang.Exception
Specified by:
storeMessage 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

updateDeliveryCount

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

generateMessageID

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

generateTransactionID

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

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.