|
||||||||||
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,
java.lang.String clientId,
java.lang.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(java.lang.String clientId,
java.lang.String subscriptionName,
java.lang.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(java.lang.String clientId,
java.lang.String subscriptionName)
|
SubscriptionInfo[] |
getAllSubscriptions()
Lists all the durable subscirptions for a given destination. |
int |
getMessageCount(java.lang.String clientId,
java.lang.String subscriberName)
Get the number of messages ready to deliver from the store to a durable subscriber |
MessageId |
getNextMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
Get the next messageId to deliver to a subscriber after the MessageId provided |
MessageId |
getPreviousMessageIdToDeliver(java.lang.String clientId,
java.lang.String subscriptionName,
MessageId id)
Get the previous messageId to deliver to a subscriber before the MessageId provided |
SubscriptionInfo |
lookupSubscription(java.lang.String clientId,
java.lang.String subscriptionName)
Finds the subscriber entry for the given consumer info |
void |
recoverNextMessages(java.lang.String clientId,
java.lang.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(java.lang.String clientId,
java.lang.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(java.lang.String clientId,
java.lang.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, java.lang.String clientId, java.lang.String subscriptionName, MessageId messageId) throws java.io.IOException
context
- clientId
- subscriptionName
- messageId
- subscriptionPersistentId
-
java.io.IOException
void deleteSubscription(java.lang.String clientId, java.lang.String subscriptionName) throws java.io.IOException
clientId
- subscriptionName
- sub
-
java.io.IOException
javax.jms.JMSException
void recoverSubscription(java.lang.String clientId, java.lang.String subscriptionName, MessageRecoveryListener listener) throws java.lang.Exception
clientId
- subscriptionName
- listener
- subscription
-
java.lang.Exception
void recoverNextMessages(java.lang.String clientId, java.lang.String subscriptionName, MessageId lastMessageId, int maxReturned, MessageRecoveryListener listener) throws java.lang.Exception
clientId
- subscriptionName
- lastMessageId
- maxReturned
- listener
-
java.lang.Exception
void resetBatching(java.lang.String clientId, java.lang.String subscriptionName, MessageId nextToDispatch)
clientId
- subscriptionName
- nextToDispatch
- MessageId getNextMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id) throws java.lang.Exception
clientId
- subscriptionName
- id
-
java.io.IOException
java.lang.Exception
MessageId getPreviousMessageIdToDeliver(java.lang.String clientId, java.lang.String subscriptionName, MessageId id) throws java.lang.Exception
clientId
- subscriptionName
- id
-
java.io.IOException
java.lang.Exception
int getMessageCount(java.lang.String clientId, java.lang.String subscriberName) throws java.io.IOException
clientId
- subscriberName
-
java.io.IOException
SubscriptionInfo lookupSubscription(java.lang.String clientId, java.lang.String subscriptionName) throws java.io.IOException
clientId
- subscriptionName
-
java.io.IOException
SubscriptionInfo[] getAllSubscriptions() throws java.io.IOException
java.io.IOException
void addSubsciption(java.lang.String clientId, java.lang.String subscriptionName, java.lang.String selector, boolean retroactive) throws java.io.IOException
clientId
- subscriptionName
- selector
- retroactive
-
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |