org.apache.qpid.server.store
Class SlowMessageStore
java.lang.Object
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 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 |
Fields inherited from interface org.apache.qpid.server.store.MessageStore |
IMMEDIATE_FUTURE |
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 |
|
SlowMessageStore
public SlowMessageStore()
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