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

BlobJDBCAdapter()

Method Summary

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 java.sql.SQLException,
                         java.io.IOException

Specified by:

doAddMessage in interface JDBCAdapter

Overrides:

doAddMessage in class DefaultJDBCAdapter

Throws:

java.sql.SQLException

java.io.IOException

doGetMessage

public byte[] doGetMessage(TransactionContext c,
                           MessageId id)
                    throws java.sql.SQLException,
                           java.io.IOException

Specified by:

doGetMessage in interface JDBCAdapter

Overrides:

doGetMessage in class DefaultJDBCAdapter

Throws:

java.sql.SQLException

java.io.IOException