public class BlobJDBCAdapter extends DefaultJDBCAdapter
batchStatments, cleanupExclusiveLock, MAX_ROWS, maxRows, prioritizedMessages, statements
Constructor and Description |
---|
BlobJDBCAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
doAddMessage(java.sql.Connection c,
long seq,
java.lang.String messageID,
java.lang.String destinationName,
byte[] data) |
byte[] |
doGetMessage(TransactionContext c,
long seq) |
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
public BlobJDBCAdapter()
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
java.sql.SQLException
javax.jms.JMSException
public byte[] doGetMessage(TransactionContext c, long seq) throws java.sql.SQLException
java.sql.SQLException
Copyright © 2005-2012. All Rights Reserved.