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