public class JournalTopicMessageStore extends JournalMessageStore implements TopicMessageStore
inFlightTxLocations, lastLocation, peristenceAdapter, transactionStore, transactionTemplate
destination, FUTURE, indexListener, prioritizedMessages
Constructor and Description |
---|
JournalTopicMessageStore(JournalPersistenceAdapter adapter,
TopicMessageStore checkpointStore,
org.apache.activemq.command.ActiveMQTopic destinationName) |
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 originalAck) |
protected void |
acknowledge(org.apache.activemq.command.MessageId messageId,
org.apache.activeio.journal.RecordLocation location,
SubscriptionKey key) |
void |
addMessage(ConnectionContext context,
org.apache.activemq.command.Message message)
Not synchronized since the Journal has better throughput if you increase
the number of concurrent writes that it is doing.
|
void |
addSubscription(org.apache.activemq.command.SubscriptionInfo subscriptionInfo,
boolean retroactive) |
org.apache.activeio.journal.RecordLocation |
checkpoint() |
void |
deleteSubscription(String clientId,
String subscriptionName) |
org.apache.activemq.command.SubscriptionInfo[] |
getAllSubscriptions() |
TopicMessageStore |
getLongTermTopicMessageStore() |
int |
getMessageCount(String clientId,
String subscriberName) |
org.apache.activemq.command.SubscriptionInfo |
lookupSubscription(String clientId,
String subscriptionName) |
void |
recoverNextMessages(String clientId,
String subscriptionName,
int maxReturned,
MessageRecoveryListener listener) |
void |
recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener) |
void |
replayAcknowledge(ConnectionContext context,
String clientId,
String subscritionName,
org.apache.activemq.command.MessageId messageId) |
void |
resetBatching(String clientId,
String subscriptionName) |
addMessageReference, checkpoint, getLongTermMessageStore, getMessage, getMessageCount, getMessageReference, recover, recoverNextMessages, removeAllMessages, removeMessage, replayAddMessage, replayRemoveMessage, resetBatching, setBatch, setMemoryUsage, start, stop
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getIndexListener, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setPrioritizedMessages, updateMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getDestination, getMessage, getMessageCount, isEmpty, isPrioritizedMessages, recover, recoverNextMessages, registerIndexListener, removeAllMessages, removeAsyncMessage, removeMessage, resetBatching, setBatch, setMemoryUsage, setPrioritizedMessages, updateMessage
public JournalTopicMessageStore(JournalPersistenceAdapter adapter, TopicMessageStore checkpointStore, org.apache.activemq.command.ActiveMQTopic destinationName)
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 org.apache.activemq.command.SubscriptionInfo lookupSubscription(String clientId, String subscriptionName) throws IOException
lookupSubscription
in interface TopicMessageStore
IOException
public void addSubscription(org.apache.activemq.command.SubscriptionInfo subscriptionInfo, boolean retroactive) throws IOException
addSubscription
in interface TopicMessageStore
IOException
public void addMessage(ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
JournalMessageStore
addMessage
in interface MessageStore
addMessage
in class JournalMessageStore
IOException
public void acknowledge(ConnectionContext context, String clientId, String subscriptionName, org.apache.activemq.command.MessageId messageId, org.apache.activemq.command.MessageAck originalAck) throws IOException
acknowledge
in interface TopicMessageStore
IOException
public void replayAcknowledge(ConnectionContext context, String clientId, String subscritionName, org.apache.activemq.command.MessageId messageId)
protected void acknowledge(org.apache.activemq.command.MessageId messageId, org.apache.activeio.journal.RecordLocation location, SubscriptionKey key)
messageId
- location
- key
- public org.apache.activeio.journal.RecordLocation checkpoint() throws IOException
checkpoint
in class JournalMessageStore
IOException
public TopicMessageStore getLongTermTopicMessageStore()
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
public void resetBatching(String clientId, String subscriptionName)
resetBatching
in interface TopicMessageStore
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.