public abstract class GenericAbstractJDBCMessageStore extends AbstractJDBCMessageStore
AbstractJDBCMessageStore.JDBCTransaction
MessageStore.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, upgrade
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getStoreLocation, getStoreLocationAsFile
public final void openMessageStore(ConfiguredObject<?> parent)
MessageStore
parent
- parent objectprotected abstract void doOpen(ConfiguredObject<?> parent) throws StoreException
StoreException
public final void upgradeStoreStructure() throws StoreException
MessageStore
StoreException
- 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()
MessageStore
closeMessageStore
in interface MessageStore
closeMessageStore
in class AbstractJDBCMessageStore
protected abstract void doClose()
protected boolean isMessageStoreOpen()
isMessageStoreOpen
in class AbstractJDBCMessageStore
protected void checkMessageStoreOpen()
checkMessageStoreOpen
in class AbstractJDBCMessageStore
protected void storedSizeChange(int contentSize)
storedSizeChange
in class AbstractJDBCMessageStore
public Transaction newTransaction()
newTransaction
in interface MessageStore
newTransaction
in class AbstractJDBCMessageStore
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.