public class StreamJDBCAdapter extends DefaultJDBCAdapter
batchStatments, MAX_ROWS, maxRows, prioritizedMessages, statements
Constructor and Description |
---|
StreamJDBCAdapter() |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
getBinaryData(ResultSet rs,
int index) |
protected void |
setBinaryData(PreparedStatement s,
int index,
byte[] data) |
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
public StreamJDBCAdapter()
protected byte[] getBinaryData(ResultSet rs, int index) throws SQLException
getBinaryData
in class DefaultJDBCAdapter
SQLException
DefaultJDBCAdapter.getBinaryData(java.sql.ResultSet,
int)
protected void setBinaryData(PreparedStatement s, int index, byte[] data) throws SQLException
setBinaryData
in class DefaultJDBCAdapter
SQLException
DefaultJDBCAdapter.setBinaryData(java.sql.PreparedStatement,
int, byte[])
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.