public class JDBCTopicMessageStore extends JDBCMessageStore implements TopicMessageStore
Modifier and Type | Field and Description |
---|---|
static String |
PROPERTY_SEQUENCE_ID_CACHE_SIZE |
adapter, audit, pendingAdditions, persistenceAdapter, rolledBackAcks, wireFormat
destination, FUTURE, indexListener, prioritizedMessages
Constructor and Description |
---|
JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
org.apache.activemq.wireformat.WireFormat wireFormat,
org.apache.activemq.command.ActiveMQTopic topic,
org.apache.activemq.ActiveMQMessageAudit audit) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
org.apache.activemq.command.MessageId messageId,
org.apache.activemq.command.MessageAck ack) |
void |
addSubscription(org.apache.activemq.command.SubscriptionInfo subscriptionInfo,
boolean retroactive) |
void |
complete(String clientId,
String subscriptionName) |
void |
deleteSubscription(String clientId,
String subscriptionName) |
org.apache.activemq.command.SubscriptionInfo[] |
getAllSubscriptions() |
long[] |
getCachedStoreSequenceId(TransactionContext transactionContext,
org.apache.activemq.command.ActiveMQDestination destination,
org.apache.activemq.command.MessageId messageId) |
int |
getMessageCount(String clientId,
String subscriberName) |
protected String |
getSubscriptionKey(String clientId,
String subscriberName) |
org.apache.activemq.command.SubscriptionInfo |
lookupSubscription(String clientId,
String subscriptionName) |
protected void |
onAdd(org.apache.activemq.command.Message message,
long sequenceId,
byte priority) |
void |
pendingCompletion(String clientId,
String subscriptionName,
long sequenceId,
byte priority) |
void |
recoverNextMessages(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
void |
recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
void |
resetBatching(String clientId,
String subscriptionName) |
addMessage, addMessageReference, getMessage, getMessageCount, getMessageReference, recover, recoverNextMessages, removeAllMessages, removeMessage, resetBatching, setBatch, setPrioritizedMessages, toString, trackRollbackAck, updateMessage
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getIndexListener, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setMemoryUsage, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addMessage, addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getMessage, getMessageCount, isEmpty, isPrioritizedMessages, recover, recoverNextMessages, registerIndexListener, removeAllMessages, removeAsyncMessage, removeMessage, resetBatching, setBatch, setMemoryUsage, setPrioritizedMessages, updateMessage
public static final String PROPERTY_SEQUENCE_ID_CACHE_SIZE
public JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter, JDBCAdapter adapter, org.apache.activemq.wireformat.WireFormat wireFormat, org.apache.activemq.command.ActiveMQTopic topic, org.apache.activemq.ActiveMQMessageAudit audit) throws IOException
IOException
public void acknowledge(ConnectionContext context, String clientId, String subscriptionName, org.apache.activemq.command.MessageId messageId, org.apache.activemq.command.MessageAck ack) throws IOException
acknowledge
in interface TopicMessageStore
IOException
public long[] getCachedStoreSequenceId(TransactionContext transactionContext, org.apache.activemq.command.ActiveMQDestination destination, org.apache.activemq.command.MessageId messageId) throws SQLException, IOException
SQLException
IOException
public void recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener) throws Exception
recoverSubscription
in interface TopicMessageStore
Exception
public void recoverNextMessages(String clientId, String subscriptionName, int maxReturned, MessageRecoveryListener listener) throws Exception
recoverNextMessages
in interface TopicMessageStore
Exception
public void resetBatching(String clientId, String subscriptionName)
resetBatching
in interface TopicMessageStore
public void pendingCompletion(String clientId, String subscriptionName, long sequenceId, byte priority)
protected void onAdd(org.apache.activemq.command.Message message, long sequenceId, byte priority)
onAdd
in class JDBCMessageStore
public void addSubscription(org.apache.activemq.command.SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException
addSubscription
in interface TopicMessageStore
IOException
public org.apache.activemq.command.SubscriptionInfo lookupSubscription(String clientId, String subscriptionName) throws IOException
lookupSubscription
in interface TopicMessageStore
IOException
TopicMessageStore.lookupSubscription(String,
String)
public void deleteSubscription(String clientId, String subscriptionName) throws IOException
deleteSubscription
in interface TopicMessageStore
IOException
public org.apache.activemq.command.SubscriptionInfo[] getAllSubscriptions() throws IOException
getAllSubscriptions
in interface TopicMessageStore
IOException
public int getMessageCount(String clientId, String subscriberName) throws IOException
getMessageCount
in interface TopicMessageStore
IOException
protected String getSubscriptionKey(String clientId, String subscriberName)
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.