public abstract class AbstractDerbyMessageStore extends AbstractJDBCMessageStore
AbstractJDBCMessageStore.JDBCTransaction
MessageStore.MessageStoreReader
_eventManager, MESSAGE_STORE_TABLE_NAMES
Constructor and Description |
---|
AbstractDerbyMessageStore() |
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 byte[] |
getBlobAsBytes(ResultSet rs,
int col) |
protected String |
getSqlBigIntType() |
protected String |
getSqlBlobType() |
protected String |
getSqlVarBinaryType(int size) |
protected boolean |
isMessageStoreOpen() |
void |
openMessageStore(ConfiguredObject<?> parent)
Initializes and opens the message store.
|
protected void |
storedSizeChange(int delta) |
protected boolean |
tableExists(String tableName,
Connection conn) |
void |
upgradeStoreStructure()
Requests that the store performs any upgrade work on the store's structure.
|
addEventListener, addMessage, createOrOpenMessageStoreDatabase, getConnection, getLogger, getNextMessageId, initMessageStore, isPersistent, newAutoCommitConnection, newConnection, newMessageStoreReader, newTransaction, onDelete, setMaximumMessageId, 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)
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 String getSqlBlobType()
getSqlBlobType
in class AbstractJDBCMessageStore
protected String getSqlVarBinaryType(int size)
getSqlVarBinaryType
in class AbstractJDBCMessageStore
protected String getSqlBigIntType()
getSqlBigIntType
in class AbstractJDBCMessageStore
protected byte[] getBlobAsBytes(ResultSet rs, int col) throws SQLException
getBlobAsBytes
in class AbstractJDBCMessageStore
SQLException
protected boolean tableExists(String tableName, Connection conn) throws SQLException
tableExists
in class AbstractJDBCMessageStore
SQLException
protected void storedSizeChange(int delta)
storedSizeChange
in class AbstractJDBCMessageStore
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.