public class BlobJDBCAdapter extends DefaultJDBCAdapter
batchStatments, MAX_ROWS, maxRows, prioritizedMessages, statements
Constructor and Description |
---|
BlobJDBCAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
doAddMessage(TransactionContext c,
long sequence,
org.apache.activemq.command.MessageId messageID,
org.apache.activemq.command.ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority,
org.apache.activemq.command.XATransactionId xid)
A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
|
byte[] |
doGetMessage(TransactionContext c,
org.apache.activemq.command.MessageId id) |
void |
setStatements(Statements statements) |
close, close, doAddMessageReference, doClearLastAck, doCommitAddOp, doCreateTables, doDeleteOldMessages, doDeleteSubscription, doDropTables, doGetAllSubscriptions, doGetDestinations, doGetDurableSubscriberMessageCount, doGetLastAckedDurableSubscriberMessageId, doGetLastMessageStoreSequenceId, doGetLastProducerSequenceId, doGetMessageById, doGetMessageCount, doGetMessageReference, doGetSubscriberEntry, doMessageIdScan, doRecordDestination, doRecover, doRecoverNextMessages, doRecoverNextMessages, doRecoverNextMessagesWithPriority, doRecoverPreparedOps, doRecoverSubscription, doRemoveAllMessages, doRemoveMessage, doSetLastAck, doSetLastAckWithPriority, doSetSubscriberEntry, doUpdateMessage, dumpTables, dumpTables, getBinaryData, getMaxRows, getStatements, getStoreSequenceId, isBatchStatements, isBatchStatments, limitQuery, printQuery, printQuery, setBatchStatements, setBatchStatments, setBinaryData, setMaxRows, setUseExternalMessageReferences
public BlobJDBCAdapter()
public void setStatements(Statements statements)
setStatements
in interface JDBCAdapter
setStatements
in class DefaultJDBCAdapter
public void doAddMessage(TransactionContext c, long sequence, org.apache.activemq.command.MessageId messageID, org.apache.activemq.command.ActiveMQDestination destination, byte[] data, long expiration, byte priority, org.apache.activemq.command.XATransactionId xid) throws SQLException, IOException
DefaultJDBCAdapter
doAddMessage
in interface JDBCAdapter
doAddMessage
in class DefaultJDBCAdapter
SQLException
IOException
public byte[] doGetMessage(TransactionContext c, org.apache.activemq.command.MessageId id) throws SQLException, IOException
doGetMessage
in interface JDBCAdapter
doGetMessage
in class DefaultJDBCAdapter
SQLException
IOException
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.