org.activemq.store.jdbc.adapter
Class BlobJDBCAdapter

java.lang.Object
  extended by org.activemq.store.jdbc.adapter.DefaultJDBCAdapter
      extended by org.activemq.store.jdbc.adapter.BlobJDBCAdapter
All Implemented Interfaces:
JDBCAdapter
Direct Known Subclasses:
InformixJDBCAdapter

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:

Version:
$Revision: 1.1 $

Nested Class Summary
 
Nested classes/interfaces inherited from interface org.activemq.store.jdbc.JDBCAdapter
JDBCAdapter.ExpiredMessageResultHandler, JDBCAdapter.MessageListResultHandler
 
Field Summary
 
Fields inherited from class org.activemq.store.jdbc.adapter.DefaultJDBCAdapter
sequenceGenerator, statementProvider
 
Constructor Summary
BlobJDBCAdapter()
           
BlobJDBCAdapter(StatementProvider provider)
           
 
Method Summary
 void doAddMessage(Connection c, long seq, String messageID, String destinationName, byte[] data)
           
 byte[] doGetMessage(Connection c, long seq)
           
 
Methods inherited from class org.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doAddMessage, doAddXid, doCreateTables, doDeleteExpiredMessage, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetExpiredMessages, doGetMessageForUpdate, doGetSubscriberEntry, doLoadPreparedTransactions, doRecover, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doRemoveXid, doSetDeadLetterFlag, doSetLastAck, doSetSubscriberEntry, getBinaryData, getMessageSequenceId, getSequenceGenerator, getStatementProvider, initSequenceGenerator, setBinaryData
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BlobJDBCAdapter

public BlobJDBCAdapter()

BlobJDBCAdapter

public BlobJDBCAdapter(StatementProvider provider)
Method Detail

doAddMessage

public void doAddMessage(Connection c,
                         long seq,
                         String messageID,
                         String destinationName,
                         byte[] data)
                  throws SQLException,
                         JMSException
Throws:
SQLException
JMSException

doGetMessage

public byte[] doGetMessage(Connection c,
                           long seq)
                    throws SQLException
Specified by:
doGetMessage in interface JDBCAdapter
Overrides:
doGetMessage in class DefaultJDBCAdapter
Throws:
SQLException


Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.