public class DerbyMessageStore extends AbstractDerbyMessageStore
AbstractJDBCMessageStore.JDBCTransaction
MessageStore.MessageStoreReader
_eventManager, MESSAGE_STORE_TABLE_NAMES
Constructor and Description |
---|
DerbyMessageStore() |
Modifier and Type | Method and Description |
---|---|
protected void |
doClose() |
protected void |
doOpen(ConfiguredObject<?> parent) |
protected Connection |
getConnection() |
protected org.slf4j.Logger |
getLogger() |
String |
getStoreLocation() |
File |
getStoreLocationAsFile() |
void |
onDelete(ConfiguredObject parent) |
checkMessageStoreOpen, closeMessageStore, getBlobAsBytes, getSqlBigIntType, getSqlBlobType, getSqlVarBinaryType, isMessageStoreOpen, openMessageStore, storedSizeChange, tableExists, upgradeStoreStructure
addEventListener, addMessage, createOrOpenMessageStoreDatabase, getNextMessageId, initMessageStore, isPersistent, newAutoCommitConnection, newConnection, newMessageStoreReader, newTransaction, setMaximumMessageId, upgrade
protected void doOpen(ConfiguredObject<?> parent)
doOpen
in class AbstractDerbyMessageStore
protected Connection getConnection() throws SQLException
getConnection
in class AbstractJDBCMessageStore
SQLException
protected void doClose()
doClose
in class AbstractDerbyMessageStore
public void onDelete(ConfiguredObject parent)
onDelete
in interface MessageStore
onDelete
in class AbstractJDBCMessageStore
protected org.slf4j.Logger getLogger()
getLogger
in class AbstractJDBCMessageStore
public String getStoreLocation()
public File getStoreLocationAsFile()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.