org.apache.activemq.store.jdbc.adapter

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 and Description
java.lang.String	acksPkName

Fields inherited from class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter

batchStatments, cleanupExclusiveLock, MAX_ROWS, maxRows, prioritizedMessages, statements

Constructor Summary

Constructors

Constructor and Description
PostgresqlJDBCAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
void	setAcksPkName(java.lang.String acksPkName)
void	setStatements(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, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessage, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetNextDurableSubscriberMessageStatement, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, getMaxRows, getStatements, getStoreSequenceId, isBatchStatments, setBatchStatments, setMaxRows, setUseExternalMessageReferences

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

acksPkName

public java.lang.String acksPkName

Constructor Detail

PostgresqlJDBCAdapter

public PostgresqlJDBCAdapter()

Method Detail

setStatements

public void setStatements(Statements statements)

Specified by:

setStatements in interface JDBCAdapter

Overrides:

setStatements in class DefaultJDBCAdapter

setAcksPkName

public void setAcksPkName(java.lang.String acksPkName)