org.apache.qpid.server.store

Class AbstractJDBCMessageStore

java.lang.Object

org.apache.qpid.server.store.AbstractJDBCMessageStore

All Implemented Interfaces:

MessageStore

Direct Known Subclasses:

AbstractDerbyMessageStore, GenericAbstractJDBCMessageStore

public abstract class AbstractJDBCMessageStore
extends Object
implements MessageStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractJDBCMessageStore.JDBCTransaction

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

MessageStore.MessageStoreReader

Field Summary

Fields

Modifier and Type	Field and Description
protected EventManager	_eventManager
static Set<String>	MESSAGE_STORE_TABLE_NAMES

Constructor Summary

Constructors

Constructor and Description
AbstractJDBCMessageStore()

Method Summary

Modifier and Type	Method and Description
void	addEventListener(EventListener eventListener, Event... events)
<T extends StorableMessageMetaData> MessageHandle<T>	addMessage(T metaData)
protected abstract void	checkMessageStoreOpen()
void	closeMessageStore() Called to close and cleanup any resources used by the message store.
protected void	createOrOpenMessageStoreDatabase()
protected abstract byte[]	getBlobAsBytes(ResultSet rs, int col)
protected abstract Connection	getConnection()
protected abstract org.slf4j.Logger	getLogger()
long	getNextMessageId()
protected abstract String	getSqlBigIntType()
protected abstract String	getSqlBlobType()
protected abstract String	getSqlVarBinaryType(int size)
protected void	initMessageStore(ConfiguredObject<?> parent)
protected abstract boolean	isMessageStoreOpen()
boolean	isPersistent() Is this store capable of persisting the data
protected Connection	newAutoCommitConnection() Convenience method to create a new Connection configured for TRANSACTION_READ_COMMITED isolation and with auto-commit transactions enabled.
protected Connection	newConnection() Convenience method to create a new Connection configured for TRANSACTION_READ_COMMITED isolation and with auto-commit transactions disabled.
MessageStore.MessageStoreReader	newMessageStoreReader()
Transaction	newTransaction()
void	onDelete(ConfiguredObject<?> parent)
protected void	setMaximumMessageId()
protected abstract void	storedSizeChange(int storeSizeIncrease)
protected boolean	tableExists(String tableName, Connection conn)
protected void	upgrade(ConfiguredObject<?> parent)

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, openMessageStore, upgradeStoreStructure

Field Detail

MESSAGE_STORE_TABLE_NAMES

public static final Set<String> MESSAGE_STORE_TABLE_NAMES

_eventManager

protected final EventManager _eventManager

Constructor Detail

AbstractJDBCMessageStore

public AbstractJDBCMessageStore()

Method Detail

isMessageStoreOpen

protected abstract boolean isMessageStoreOpen()

checkMessageStoreOpen

protected abstract void checkMessageStoreOpen()

setMaximumMessageId

protected void setMaximumMessageId()

upgrade

protected void upgrade(ConfiguredObject<?> parent)
                throws StoreException

Throws:

StoreException

initMessageStore

protected void initMessageStore(ConfiguredObject<?> parent)

closeMessageStore

public 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

getLogger

protected abstract org.slf4j.Logger getLogger()

getSqlBlobType

protected abstract String getSqlBlobType()

getSqlVarBinaryType

protected abstract String getSqlVarBinaryType(int size)

getSqlBigIntType

protected abstract String getSqlBigIntType()

createOrOpenMessageStoreDatabase

protected void createOrOpenMessageStoreDatabase()
                                         throws StoreException

Throws:

StoreException

tableExists

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

Throws:

SQLException

addMessage

public <T extends StorableMessageMetaData> MessageHandle<T> addMessage(T metaData)

Specified by:

addMessage in interface MessageStore

getNextMessageId

public long getNextMessageId()

Specified by:

getNextMessageId in interface MessageStore

newAutoCommitConnection

protected Connection newAutoCommitConnection()
                                      throws SQLException

Convenience method to create a new Connection configured for TRANSACTION_READ_COMMITED isolation and with auto-commit transactions enabled.

Throws:

SQLException

newConnection

protected Connection newConnection()
                            throws SQLException

Convenience method to create a new Connection configured for TRANSACTION_READ_COMMITED isolation and with auto-commit transactions disabled.

Throws:

SQLException

getConnection

protected abstract Connection getConnection()
                                     throws SQLException

Throws:

SQLException

newTransaction

public Transaction newTransaction()

Specified by:

newTransaction in interface MessageStore

getBlobAsBytes

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

Throws:

SQLException

isPersistent

public boolean isPersistent()

Description copied from interface: MessageStore

Is this store capable of persisting the data

Specified by:

isPersistent in interface MessageStore

Returns:

true if this store is capable of persisting data

addEventListener

public void addEventListener(EventListener eventListener,
                             Event... events)

Specified by:

addEventListener in interface MessageStore

newMessageStoreReader

public MessageStore.MessageStoreReader newMessageStoreReader()

Specified by:

newMessageStoreReader in interface MessageStore

storedSizeChange

protected abstract void storedSizeChange(int storeSizeIncrease)

onDelete

public void onDelete(ConfiguredObject<?> parent)

Specified by:

onDelete in interface MessageStore