public abstract class GenericAbstractJDBCMessageStore extends AbstractJDBCMessageStore
AbstractJDBCMessageStore.JDBCTransactionMessageStore.MessageStoreReader_eventManager, MESSAGE_STORE_TABLE_NAMES| Constructor and Description |
|---|
GenericAbstractJDBCMessageStore() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
checkMessageStoreOpen() |
void |
closeMessageStore()
Called to close and cleanup any resources used by the message store.
|
protected abstract void |
doClose() |
protected abstract void |
doOpen(ConfiguredObject<?> parent) |
protected boolean |
isMessageStoreOpen() |
Transaction |
newTransaction() |
void |
openMessageStore(ConfiguredObject<?> parent)
Initializes and opens the message store.
|
protected void |
storedSizeChange(int contentSize) |
void |
upgradeStoreStructure()
Requests that the store performs any upgrade work on the store's structure.
|
addEventListener, addMessage, createOrOpenMessageStoreDatabase, getBlobAsBytes, getConnection, getLogger, getNextMessageId, getSqlBigIntType, getSqlBlobType, getSqlVarBinaryType, initMessageStore, isPersistent, newAutoCommitConnection, newConnection, newMessageStoreReader, onDelete, setMaximumMessageId, tableExists, upgradeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetStoreLocation, getStoreLocationAsFilepublic final void openMessageStore(ConfiguredObject<?> parent)
MessageStoreparent - parent objectprotected abstract void doOpen(ConfiguredObject<?> parent) throws StoreException
StoreExceptionpublic final void upgradeStoreStructure()
throws StoreException
MessageStoreStoreException - signals that a problem was encountered trying to upgrade the store.
Implementations, on encountering a problem, should endeavour to leave the store in its
original state.public final void closeMessageStore()
MessageStorecloseMessageStore in interface MessageStorecloseMessageStore in class AbstractJDBCMessageStoreprotected abstract void doClose()
protected boolean isMessageStoreOpen()
isMessageStoreOpen in class AbstractJDBCMessageStoreprotected void checkMessageStoreOpen()
checkMessageStoreOpen in class AbstractJDBCMessageStoreprotected void storedSizeChange(int contentSize)
storedSizeChange in class AbstractJDBCMessageStorepublic Transaction newTransaction()
newTransaction in interface MessageStorenewTransaction in class AbstractJDBCMessageStoreCopyright © 2006–2016 The Apache Software Foundation. All rights reserved.