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

java.lang.Object
  extended by org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
      extended by 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


Copyright © 2005-2016. All Rights Reserved.