|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface TopicMessageStore
A MessageStore for durable topic subscriptions
Method Summary | |
---|---|
void |
acknowledge(ConnectionContext context,
String clientId,
String subscriptionName,
MessageId messageId)
Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint |
void |
addSubsciption(String clientId,
String subscriptionName,
String selector,
boolean retroactive)
Inserts the subscriber info due to a subscription change If this is a new subscription and the retroactive is false, then the last message sent to the topic should be set as the last message acknowledged by they new subscription. |
void |
deleteSubscription(String clientId,
String subscriptionName)
|
SubscriptionInfo[] |
getAllSubscriptions()
Lists all the durable subscirptions for a given destination. |
int |
getMessageCount(String clientId,
String subscriberName)
Get the number of messages ready to deliver from the store to a durable subscriber |
MessageId |
getNextMessageIdToDeliver(String clientId,
String subscriptionName,
MessageId id)
Get the next messageId to deliver to a subscriber after the MessageId provided |
MessageId |
getPreviousMessageIdToDeliver(String clientId,
String subscriptionName,
MessageId id)
Get the previous messageId to deliver to a subscriber before the MessageId provided |
SubscriptionInfo |
lookupSubscription(String clientId,
String subscriptionName)
Finds the subscriber entry for the given consumer info |
void |
recoverNextMessages(String clientId,
String subscriptionName,
MessageId lastMessageId,
int maxReturned,
MessageRecoveryListener listener)
For an active subscription - retrieve messages from the store for the subscriber after the lastMessageId messageId |
void |
recoverSubscription(String clientId,
String subscriptionName,
MessageRecoveryListener listener)
For the new subscription find the last acknowledged message ID and then find any new messages since then and dispatch them to the subscription. |
void |
resetBatching(String clientId,
String subscriptionName,
MessageId nextToDispatch)
A hint to the Store to reset any batching state for a durable subsriber |
Methods inherited from interface org.apache.activemq.store.MessageStore |
---|
addMessage, addMessageReference, getDestination, getMessage, getMessageReference, recover, removeAllMessages, removeMessage, setUsageManager |
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
void acknowledge(ConnectionContext context, String clientId, String subscriptionName, MessageId messageId) throws IOException
context
- clientId
- subscriptionName
- messageId
- subscriptionPersistentId
-
IOException
void deleteSubscription(String clientId, String subscriptionName) throws IOException
clientId
- subscriptionName
- sub
-
IOException
javax.jms.JMSException
void recoverSubscription(String clientId, String subscriptionName, MessageRecoveryListener listener) throws Exception
clientId
- subscriptionName
- listener
- subscription
-
Exception
void recoverNextMessages(String clientId, String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener) throws Exception
clientId
- subscriptionName
- lastMessageId
- maxReturned
- listener
-
Exception
void resetBatching(String clientId, String subscriptionName, MessageId nextToDispatch)
clientId
- subscriptionName
- nextToDispatch
- MessageId getNextMessageIdToDeliver(String clientId, String subscriptionName, MessageId id) throws Exception
clientId
- subscriptionName
- id
-
IOException
Exception
MessageId getPreviousMessageIdToDeliver(String clientId, String subscriptionName, MessageId id) throws Exception
clientId
- subscriptionName
- id
-
IOException
Exception
int getMessageCount(String clientId, String subscriberName) throws IOException
clientId
- subscriberName
-
IOException
SubscriptionInfo lookupSubscription(String clientId, String subscriptionName) throws IOException
clientId
- subscriptionName
-
IOException
SubscriptionInfo[] getAllSubscriptions() throws IOException
IOException
void addSubsciption(String clientId, String subscriptionName, String selector, boolean retroactive) throws IOException
clientId
- subscriptionName
- selector
- retroactive
-
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |