Class PostgresqlJDBCAdapter
- java.lang.Object
-
- org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
-
- org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter
-
- org.apache.activemq.store.jdbc.adapter.PostgresqlJDBCAdapter
-
- All Implemented Interfaces:
JDBCAdapter
public class PostgresqlJDBCAdapter extends BytesJDBCAdapter
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter. Subclassing is encouraged to override the default implementation of methods to account for differences in JDBC Driver implementations. The JDBCAdapter inserts and extracts BLOB data using the getBytes()/setBytes() operations. The databases/JDBC drivers that use this adapter are:
-
-
Field Summary
Fields Modifier and Type Field Description StringacksPkName-
Fields inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
batchStatments, MAX_ROWS, maxRows, prioritizedMessages, statements
-
-
Constructor Summary
Constructors Constructor Description PostgresqlJDBCAdapter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringlimitQuery(String query)voidsetAcksPkName(String acksPkName)voidsetStatements(Statements statements)-
Methods inherited from class org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter
getBinaryData, setBinaryData
-
Methods inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
close, close, doAddMessage, doAddMessageReference, doClearLastAck, doCommitAddOp, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessage, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverPreparedOps, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, doUpdateMessage, dumpTables, dumpTables, getMaxRows, getStatements, getStoreSequenceId, isBatchStatements, isBatchStatments, printQuery, printQuery, setBatchStatements, setBatchStatments, setMaxRows, setUseExternalMessageReferences
-
-
-
-
Field Detail
-
acksPkName
public String acksPkName
-
-
Method Detail
-
setStatements
public void setStatements(Statements statements)
- Specified by:
setStatementsin interfaceJDBCAdapter- Overrides:
setStatementsin classDefaultJDBCAdapter
-
setAcksPkName
public void setAcksPkName(String acksPkName)
-
limitQuery
public String limitQuery(String query)
- Specified by:
limitQueryin interfaceJDBCAdapter- Overrides:
limitQueryin classDefaultJDBCAdapter
-
-