org.apache.qpid.server.store.derby

Class AbstractDerbyMessageStore

java.lang.Object

org.apache.qpid.server.store.AbstractJDBCMessageStore

org.apache.qpid.server.store.derby.AbstractDerbyMessageStore

All Implemented Interfaces:

MessageStore

Direct Known Subclasses:

DerbyMessageStore

public abstract class AbstractDerbyMessageStore
extends AbstractJDBCMessageStore

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.store.AbstractJDBCMessageStore

AbstractJDBCMessageStore.JDBCTransaction

Nested classes/interfaces inherited from interface org.apache.qpid.server.store.MessageStore

MessageStore.MessageStoreReader

Field Summary

Fields inherited from class org.apache.qpid.server.store.AbstractJDBCMessageStore

_eventManager, MESSAGE_STORE_TABLE_NAMES

Constructor Summary

Constructors

Constructor and Description
AbstractDerbyMessageStore()

Method Summary

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.

Methods inherited from class org.apache.qpid.server.store.AbstractJDBCMessageStore

addEventListener, addMessage, createOrOpenMessageStoreDatabase, getConnection, getLogger, getNextMessageId, initMessageStore, isPersistent, newAutoCommitConnection, newConnection, newMessageStoreReader, newTransaction, onDelete, setMaximumMessageId, upgrade

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

getStoreLocation, getStoreLocationAsFile

Constructor Detail

AbstractDerbyMessageStore

public AbstractDerbyMessageStore()

Method Detail

openMessageStore

public final void openMessageStore(ConfiguredObject<?> parent)

Description copied from interface: MessageStore

Initializes and opens the message store.

Parameters:

parent - parent object

doOpen

protected abstract void doOpen(ConfiguredObject<?> parent)

upgradeStoreStructure

public final void upgradeStoreStructure()
                                 throws StoreException

Description copied from interface: MessageStore

Requests that the store performs any upgrade work on the store's structure. If there is no upgrade work to be done, this method should return without doing anything.

Throws:

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.

closeMessageStore

public final void closeMessageStore()

Description copied from interface: MessageStore

Called to close and cleanup any resources used by the message store.

Specified by:

closeMessageStore in interface MessageStore

Overrides:

closeMessageStore in class AbstractJDBCMessageStore

doClose

protected abstract void doClose()

isMessageStoreOpen

protected boolean isMessageStoreOpen()

Specified by:

isMessageStoreOpen in class AbstractJDBCMessageStore

checkMessageStoreOpen

protected void checkMessageStoreOpen()

Specified by:

checkMessageStoreOpen in class AbstractJDBCMessageStore

getSqlBlobType

protected String getSqlBlobType()

Specified by:

getSqlBlobType in class AbstractJDBCMessageStore

getSqlVarBinaryType

protected String getSqlVarBinaryType(int size)

Specified by:

getSqlVarBinaryType in class AbstractJDBCMessageStore

getSqlBigIntType

protected String getSqlBigIntType()

Specified by:

getSqlBigIntType in class AbstractJDBCMessageStore

getBlobAsBytes

protected byte[] getBlobAsBytes(ResultSet rs,
                                int col)
                         throws SQLException

Specified by:

getBlobAsBytes in class AbstractJDBCMessageStore

Throws:

SQLException

tableExists

protected boolean tableExists(String tableName,
                              Connection conn)
                       throws SQLException

Overrides:

tableExists in class AbstractJDBCMessageStore

Throws:

SQLException

storedSizeChange

protected void storedSizeChange(int delta)

Specified by:

storedSizeChange in class AbstractJDBCMessageStore