Package org.apache.activemq.store.jdbc.adapter

Class StreamJDBCAdapter

java.lang.Object

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

org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter

All Implemented Interfaces:

JDBCAdapter

Direct Known Subclasses:

AxionJDBCAdapter

public class StreamJDBCAdapter
extends DefaultJDBCAdapter

This JDBCAdapter inserts and extracts BLOB data using the setBinaryStream()/getBinaryStream() operations. The databases/JDBC drivers that use this adapter are:

• Axion

Field Summary

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

batchStatments, MAX_ROWS, maxRows, prioritizedMessages, statements

Constructor Summary

Constructors

Constructor	Description
StreamJDBCAdapter()

Method Summary

Modifier and Type	Method	Description
protected byte[]	getBinaryData(ResultSet rs, int index)
protected void	setBinaryData(PreparedStatement s, int index, byte[] data)

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

close, close, doAddMessage, doAddMessageReference, doClearLastAck, doCommitAddOp, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessage, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverPreparedOps, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, doUpdateMessage, dumpTables, dumpTables, getMaxRows, getStatements, getStoreSequenceId, isBatchStatements, isBatchStatments, limitQuery, printQuery, printQuery, setBatchStatements, setBatchStatments, setMaxRows, setStatements, setUseExternalMessageReferences

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamJDBCAdapter

public StreamJDBCAdapter()

Method Detail

getBinaryData

protected byte[] getBinaryData(ResultSet rs,
                               int index)
                        throws SQLException

Overrides:

getBinaryData in class DefaultJDBCAdapter

Throws:

SQLException

See Also:

DefaultJDBCAdapter.getBinaryData(java.sql.ResultSet, int)

setBinaryData

protected void setBinaryData(PreparedStatement s,
                             int index,
                             byte[] data)
                      throws SQLException

Overrides:

setBinaryData in class DefaultJDBCAdapter

Throws:

SQLException

See Also:

DefaultJDBCAdapter.setBinaryData(java.sql.PreparedStatement, int, byte[])