public class BlobJDBCAdapter extends DefaultJDBCAdapter
batchStatments, cleanupExclusiveLock, MAX_ROWS, maxRows, prioritizedMessages, statements
Constructor and Description |
---|
BlobJDBCAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
doAddMessage(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority) |
byte[] |
doGetMessage(TransactionContext c,
MessageId id) |
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
public BlobJDBCAdapter()
public void doAddMessage(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, byte[] data, long expiration, byte priority) throws java.sql.SQLException, java.io.IOException
doAddMessage
in interface JDBCAdapter
doAddMessage
in class DefaultJDBCAdapter
java.sql.SQLException
java.io.IOException
public byte[] doGetMessage(TransactionContext c, MessageId id) throws java.sql.SQLException, java.io.IOException
doGetMessage
in interface JDBCAdapter
doGetMessage
in class DefaultJDBCAdapter
java.sql.SQLException
java.io.IOException
Copyright © 2005-2017. All Rights Reserved.