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, OracleJDBCAdapter

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(java.sql.Connection c, long seq, java.lang.String messageID, java.lang.String destinationName, byte[] data)
byte[]	doGetMessage(TransactionContext c, long seq)

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

doAddMessage, doAddMessageReference, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessage, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetNextDurableSubscriberMessageStatement, doGetSubscriberEntry, doMessageIdScan, 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(java.sql.Connection c,
                         long seq,
                         java.lang.String messageID,
                         java.lang.String destinationName,
                         byte[] data)
                  throws java.sql.SQLException,
                         javax.jms.JMSException

Throws:

java.sql.SQLException

javax.jms.JMSException

doGetMessage

public byte[] doGetMessage(TransactionContext c,
                           long seq)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException