public class DefaultJDBCAdapter extends java.lang.Object implements JDBCAdapter
Modifier and Type | Field and Description |
---|---|
protected boolean |
batchStatments |
protected java.util.concurrent.locks.ReadWriteLock |
cleanupExclusiveLock |
static int |
MAX_ROWS |
protected int |
maxRows |
protected boolean |
prioritizedMessages |
protected Statements |
statements |
Constructor and Description |
---|
DefaultJDBCAdapter() |
Modifier and Type | Method and Description |
---|---|
protected static void |
close(java.sql.PreparedStatement s) |
protected static void |
close(java.sql.ResultSet rs) |
void |
doAddMessage(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
byte[] data,
long expiration,
byte priority) |
void |
doAddMessageReference(TransactionContext c,
long sequence,
MessageId messageID,
ActiveMQDestination destination,
long expirationTime,
java.lang.String messageRef) |
void |
doCreateTables(TransactionContext c) |
void |
doDeleteOldMessages(TransactionContext c) |
void |
doDeleteSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName) |
void |
doDropTables(TransactionContext c) |
SubscriptionInfo[] |
doGetAllSubscriptions(TransactionContext c,
ActiveMQDestination destination) |
java.util.Set<ActiveMQDestination> |
doGetDestinations(TransactionContext c) |
int |
doGetDurableSubscriberMessageCount(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
boolean isPrioritizedMessages) |
long |
doGetLastAckedDurableSubscriberMessageId(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName) |
long |
doGetLastMessageStoreSequenceId(TransactionContext c) |
long |
doGetLastProducerSequenceId(TransactionContext c,
ProducerId id) |
byte[] |
doGetMessage(TransactionContext c,
MessageId id) |
byte[] |
doGetMessageById(TransactionContext c,
long storeSequenceId) |
int |
doGetMessageCount(TransactionContext c,
ActiveMQDestination destination) |
java.lang.String |
doGetMessageReference(TransactionContext c,
long seq) |
byte[] |
doGetNextDurableSubscriberMessageStatement(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriberName) |
SubscriptionInfo |
doGetSubscriberEntry(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName) |
void |
doMessageIdScan(TransactionContext c,
int limit,
JDBCMessageIdScanListener listener) |
void |
doRecordDestination(TransactionContext c,
ActiveMQDestination destination) |
void |
doRecover(TransactionContext c,
ActiveMQDestination destination,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
long nextSeq,
long priority,
int maxReturned,
boolean isPrioritizedMessages,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessages(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
doRecoverNextMessagesWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority,
int maxReturned,
JDBCMessageRecoveryListener listener) |
void |
doRecoverSubscription(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
JDBCMessageRecoveryListener listener) |
void |
doRemoveAllMessages(TransactionContext c,
ActiveMQDestination destinationName) |
void |
doRemoveMessage(TransactionContext c,
long seq) |
void |
doSetLastAck(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long priority) |
void |
doSetLastAckWithPriority(TransactionContext c,
ActiveMQDestination destination,
java.lang.String clientId,
java.lang.String subscriptionName,
long seq,
long prio) |
void |
doSetSubscriberEntry(TransactionContext c,
SubscriptionInfo info,
boolean retroactive,
boolean isPrioritizedMessages) |
protected byte[] |
getBinaryData(java.sql.ResultSet rs,
int index) |
int |
getMaxRows() |
Statements |
getStatements() |
long[] |
getStoreSequenceId(TransactionContext c,
ActiveMQDestination destination,
MessageId messageID) |
boolean |
isBatchStatments() |
void |
setBatchStatments(boolean batchStatments) |
protected void |
setBinaryData(java.sql.PreparedStatement s,
int index,
byte[] data) |
void |
setMaxRows(int maxRows) |
void |
setStatements(Statements statements) |
void |
setUseExternalMessageReferences(boolean useExternalMessageReferences) |
public static final int MAX_ROWS
protected Statements statements
protected boolean batchStatments
protected boolean prioritizedMessages
protected java.util.concurrent.locks.ReadWriteLock cleanupExclusiveLock
protected int maxRows
public DefaultJDBCAdapter()
protected void setBinaryData(java.sql.PreparedStatement s, int index, byte[] data) throws java.sql.SQLException
java.sql.SQLException
protected byte[] getBinaryData(java.sql.ResultSet rs, int index) throws java.sql.SQLException
java.sql.SQLException
public void doCreateTables(TransactionContext c) throws java.sql.SQLException, java.io.IOException
doCreateTables
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doDropTables(TransactionContext c) throws java.sql.SQLException, java.io.IOException
doDropTables
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public long doGetLastMessageStoreSequenceId(TransactionContext c) throws java.sql.SQLException, java.io.IOException
doGetLastMessageStoreSequenceId
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public byte[] doGetMessageById(TransactionContext c, long storeSequenceId) throws java.sql.SQLException, java.io.IOException
doGetMessageById
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
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
java.sql.SQLException
java.io.IOException
public void doAddMessageReference(TransactionContext c, long sequence, MessageId messageID, ActiveMQDestination destination, long expirationTime, java.lang.String messageRef) throws java.sql.SQLException, java.io.IOException
doAddMessageReference
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public long[] getStoreSequenceId(TransactionContext c, ActiveMQDestination destination, MessageId messageID) throws java.sql.SQLException, java.io.IOException
getStoreSequenceId
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public byte[] doGetMessage(TransactionContext c, MessageId id) throws java.sql.SQLException, java.io.IOException
doGetMessage
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public java.lang.String doGetMessageReference(TransactionContext c, long seq) throws java.sql.SQLException, java.io.IOException
doGetMessageReference
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doRemoveMessage(TransactionContext c, long seq) throws java.sql.SQLException, java.io.IOException
doRemoveMessage
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doRecover(TransactionContext c, ActiveMQDestination destination, JDBCMessageRecoveryListener listener) throws java.lang.Exception
doRecover
in interface JDBCAdapter
java.lang.Exception
public void doMessageIdScan(TransactionContext c, int limit, JDBCMessageIdScanListener listener) throws java.sql.SQLException, java.io.IOException
doMessageIdScan
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doSetLastAckWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long prio) throws java.sql.SQLException, java.io.IOException
doSetLastAckWithPriority
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doSetLastAck(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority) throws java.sql.SQLException, java.io.IOException
doSetLastAck
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doRecoverSubscription(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, JDBCMessageRecoveryListener listener) throws java.lang.Exception
doRecoverSubscription
in interface JDBCAdapter
java.lang.Exception
public void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws java.lang.Exception
doRecoverNextMessages
in interface JDBCAdapter
java.lang.Exception
public void doRecoverNextMessagesWithPriority(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, long seq, long priority, int maxReturned, JDBCMessageRecoveryListener listener) throws java.lang.Exception
doRecoverNextMessagesWithPriority
in interface JDBCAdapter
java.lang.Exception
public int doGetDurableSubscriberMessageCount(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName, boolean isPrioritizedMessages) throws java.sql.SQLException, java.io.IOException
doGetDurableSubscriberMessageCount
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doSetSubscriberEntry(TransactionContext c, SubscriptionInfo info, boolean retroactive, boolean isPrioritizedMessages) throws java.sql.SQLException, java.io.IOException
doSetSubscriberEntry
in interface JDBCAdapter
c
- info
- retroactive
- java.sql.SQLException
java.io.IOException
public SubscriptionInfo doGetSubscriberEntry(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName) throws java.sql.SQLException, java.io.IOException
doGetSubscriberEntry
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public SubscriptionInfo[] doGetAllSubscriptions(TransactionContext c, ActiveMQDestination destination) throws java.sql.SQLException, java.io.IOException
doGetAllSubscriptions
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doRemoveAllMessages(TransactionContext c, ActiveMQDestination destinationName) throws java.sql.SQLException, java.io.IOException
doRemoveAllMessages
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doDeleteSubscription(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriptionName) throws java.sql.SQLException, java.io.IOException
doDeleteSubscription
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doDeleteOldMessages(TransactionContext c) throws java.sql.SQLException, java.io.IOException
doDeleteOldMessages
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public long doGetLastAckedDurableSubscriberMessageId(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriberName) throws java.sql.SQLException, java.io.IOException
doGetLastAckedDurableSubscriberMessageId
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
protected static void close(java.sql.PreparedStatement s)
protected static void close(java.sql.ResultSet rs)
public java.util.Set<ActiveMQDestination> doGetDestinations(TransactionContext c) throws java.sql.SQLException, java.io.IOException
doGetDestinations
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public boolean isBatchStatments()
public void setBatchStatments(boolean batchStatments)
batchStatments
- public void setUseExternalMessageReferences(boolean useExternalMessageReferences)
setUseExternalMessageReferences
in interface JDBCAdapter
public Statements getStatements()
public void setStatements(Statements statements)
setStatements
in interface JDBCAdapter
public int getMaxRows()
getMaxRows
in interface JDBCAdapter
public void setMaxRows(int maxRows)
setMaxRows
in interface JDBCAdapter
public void doRecordDestination(TransactionContext c, ActiveMQDestination destination) throws java.sql.SQLException, java.io.IOException
doRecordDestination
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public byte[] doGetNextDurableSubscriberMessageStatement(TransactionContext c, ActiveMQDestination destination, java.lang.String clientId, java.lang.String subscriberName) throws java.sql.SQLException, java.io.IOException
c
- destination
- clientId
- subscriberName
- java.sql.SQLException
java.io.IOException
public int doGetMessageCount(TransactionContext c, ActiveMQDestination destination) throws java.sql.SQLException, java.io.IOException
doGetMessageCount
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
public void doRecoverNextMessages(TransactionContext c, ActiveMQDestination destination, long nextSeq, long priority, int maxReturned, boolean isPrioritizedMessages, JDBCMessageRecoveryListener listener) throws java.lang.Exception
doRecoverNextMessages
in interface JDBCAdapter
java.lang.Exception
public long doGetLastProducerSequenceId(TransactionContext c, ProducerId id) throws java.sql.SQLException, java.io.IOException
doGetLastProducerSequenceId
in interface JDBCAdapter
java.sql.SQLException
java.io.IOException
Copyright © 2005-2017. All Rights Reserved.