org.apache.qpid.server.store
Class SlowMessageStore

java.lang.Object
  extended by org.apache.qpid.server.store.SlowMessageStore
All Implemented Interfaces:
org.apache.qpid.server.store.DurableConfigurationStore, org.apache.qpid.server.store.MessageStore, org.apache.qpid.server.store.TransactionLog

public class SlowMessageStore
extends Object
implements org.apache.qpid.server.store.MessageStore


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.store.DurableConfigurationStore
org.apache.qpid.server.store.DurableConfigurationStore.Source
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.store.TransactionLog
org.apache.qpid.server.store.TransactionLog.StoreFuture, org.apache.qpid.server.store.TransactionLog.Transaction
 
Field Summary
 
Fields inherited from interface org.apache.qpid.server.store.MessageStore
IMMEDIATE_FUTURE
 
Constructor Summary
SlowMessageStore()
           
 
Method Summary
<M extends org.apache.qpid.server.store.StorableMessageMetaData>
org.apache.qpid.server.store.StoredMessage<M>
addMessage(M metaData)
           
 void bindQueue(org.apache.qpid.server.exchange.Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.server.queue.AMQQueue queue, org.apache.qpid.framing.FieldTable args)
           
 void close()
           
 void configureConfigStore(String name, org.apache.qpid.server.store.ConfigurationRecoveryHandler recoveryHandler, Configuration config, org.apache.qpid.server.logging.LogSubject logSubject)
           
 void configureMessageStore(String name, org.apache.qpid.server.store.MessageStoreRecoveryHandler recoveryHandler, Configuration config, org.apache.qpid.server.logging.LogSubject logSubject)
           
 void configureTransactionLog(String name, org.apache.qpid.server.store.TransactionLogRecoveryHandler recoveryHandler, Configuration storeConfiguration, org.apache.qpid.server.logging.LogSubject logSubject)
           
 void createExchange(org.apache.qpid.server.exchange.Exchange exchange)
           
 void createQueue(org.apache.qpid.server.queue.AMQQueue queue)
           
 void createQueue(org.apache.qpid.server.queue.AMQQueue queue, org.apache.qpid.framing.FieldTable arguments)
           
 org.apache.qpid.server.message.ServerMessage getMessage(Long messageNumber)
           
 boolean isPersistent()
           
 org.apache.qpid.server.store.TransactionLog.Transaction newTransaction()
           
 void removeExchange(org.apache.qpid.server.exchange.Exchange exchange)
           
 void removeQueue(org.apache.qpid.server.queue.AMQQueue queue)
           
 void storeContent(Long messageNumber, long offset, ByteBuffer body)
           
 void storeMessageHeader(Long messageNumber, org.apache.qpid.server.message.ServerMessage message)
           
 void unbindQueue(org.apache.qpid.server.exchange.Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.server.queue.AMQQueue queue, org.apache.qpid.framing.FieldTable args)
           
 void updateQueue(org.apache.qpid.server.queue.AMQQueue queue)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.qpid.server.store.MessageStore
 

Constructor Detail

SlowMessageStore

public SlowMessageStore()
Method Detail

configureConfigStore

public void configureConfigStore(String name,
                                 org.apache.qpid.server.store.ConfigurationRecoveryHandler recoveryHandler,
                                 Configuration config,
                                 org.apache.qpid.server.logging.LogSubject logSubject)
                          throws Exception
Specified by:
configureConfigStore in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
Exception

configureMessageStore

public void configureMessageStore(String name,
                                  org.apache.qpid.server.store.MessageStoreRecoveryHandler recoveryHandler,
                                  Configuration config,
                                  org.apache.qpid.server.logging.LogSubject logSubject)
                           throws Exception
Specified by:
configureMessageStore in interface org.apache.qpid.server.store.MessageStore
Throws:
Exception

close

public void close()
           throws Exception
Specified by:
close in interface org.apache.qpid.server.store.MessageStore
Throws:
Exception

addMessage

public <M extends org.apache.qpid.server.store.StorableMessageMetaData> org.apache.qpid.server.store.StoredMessage<M> addMessage(M metaData)
Specified by:
addMessage in interface org.apache.qpid.server.store.MessageStore

createExchange

public void createExchange(org.apache.qpid.server.exchange.Exchange exchange)
                    throws org.apache.qpid.AMQStoreException
Specified by:
createExchange in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

removeExchange

public void removeExchange(org.apache.qpid.server.exchange.Exchange exchange)
                    throws org.apache.qpid.AMQStoreException
Specified by:
removeExchange in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

bindQueue

public void bindQueue(org.apache.qpid.server.exchange.Exchange exchange,
                      org.apache.qpid.framing.AMQShortString routingKey,
                      org.apache.qpid.server.queue.AMQQueue queue,
                      org.apache.qpid.framing.FieldTable args)
               throws org.apache.qpid.AMQStoreException
Specified by:
bindQueue in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

unbindQueue

public void unbindQueue(org.apache.qpid.server.exchange.Exchange exchange,
                        org.apache.qpid.framing.AMQShortString routingKey,
                        org.apache.qpid.server.queue.AMQQueue queue,
                        org.apache.qpid.framing.FieldTable args)
                 throws org.apache.qpid.AMQStoreException
Specified by:
unbindQueue in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

createQueue

public void createQueue(org.apache.qpid.server.queue.AMQQueue queue)
                 throws org.apache.qpid.AMQStoreException
Specified by:
createQueue in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

createQueue

public void createQueue(org.apache.qpid.server.queue.AMQQueue queue,
                        org.apache.qpid.framing.FieldTable arguments)
                 throws org.apache.qpid.AMQStoreException
Specified by:
createQueue in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

removeQueue

public void removeQueue(org.apache.qpid.server.queue.AMQQueue queue)
                 throws org.apache.qpid.AMQStoreException
Specified by:
removeQueue in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException

configureTransactionLog

public void configureTransactionLog(String name,
                                    org.apache.qpid.server.store.TransactionLogRecoveryHandler recoveryHandler,
                                    Configuration storeConfiguration,
                                    org.apache.qpid.server.logging.LogSubject logSubject)
                             throws Exception
Specified by:
configureTransactionLog in interface org.apache.qpid.server.store.TransactionLog
Throws:
Exception

newTransaction

public org.apache.qpid.server.store.TransactionLog.Transaction newTransaction()
Specified by:
newTransaction in interface org.apache.qpid.server.store.TransactionLog

isPersistent

public boolean isPersistent()
Specified by:
isPersistent in interface org.apache.qpid.server.store.MessageStore

storeMessageHeader

public void storeMessageHeader(Long messageNumber,
                               org.apache.qpid.server.message.ServerMessage message)

storeContent

public void storeContent(Long messageNumber,
                         long offset,
                         ByteBuffer body)

getMessage

public org.apache.qpid.server.message.ServerMessage getMessage(Long messageNumber)

updateQueue

public void updateQueue(org.apache.qpid.server.queue.AMQQueue queue)
                 throws org.apache.qpid.AMQStoreException
Specified by:
updateQueue in interface org.apache.qpid.server.store.DurableConfigurationStore
Throws:
org.apache.qpid.AMQStoreException


Licensed to the Apache Software Foundation