org.apache.activemq.store.jdbc.adapter

Class BlobJDBCAdapter

java.lang.Object

org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter

org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter

All Implemented Interfaces:

JDBCAdapter

Direct Known Subclasses:

InformixJDBCAdapter, OracleBlobJDBCAdapter

public class BlobJDBCAdapter
extends DefaultJDBCAdapter

This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations. This is a little more involved since to insert a blob you have to: 1: insert empty blob. 2: select the blob 3: finally update the blob with data value. The databases/JDBC drivers that use this adapter are:

Field Summary

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

batchStatments, cleanupExclusiveLock, MAX_ROWS, maxRows, prioritizedMessages, statements

Constructor Summary

Constructors

Constructor and Description
BlobJDBCAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
void	doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority)
byte[]	doGetMessage(TransactionContext c, MessageId id)

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

close, close, doAddMessageReference, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetNextDurableSubscriberMessageStatement, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, getBinaryData, getMaxRows, getStatements, getStoreSequenceId, isBatchStatments, setBatchStatments, setBinaryData, setMaxRows, setStatements, setUseExternalMessageReferences

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobJDBCAdapter

public BlobJDBCAdapter()

Method Detail

doAddMessage

public void doAddMessage(TransactionContext c,
                long sequence,
                MessageId messageID,
                ActiveMQDestination destination,
                byte[] data,
                long expiration,
                byte priority)
                  throws SQLException,
                         IOException

Specified by:

doAddMessage in interface JDBCAdapter

Overrides:

doAddMessage in class DefaultJDBCAdapter

Throws:

SQLException

IOException

doGetMessage

public byte[] doGetMessage(TransactionContext c,
                  MessageId id)
                    throws SQLException,
                           IOException

Specified by:

doGetMessage in interface JDBCAdapter

Overrides:

doGetMessage in class DefaultJDBCAdapter

Throws:

SQLException

IOException