org.activemq.service
Interface TopicMessageContainer

All Superinterfaces:
MessageContainer, Service
All Known Implementing Classes:
DurableTopicMessageContainer

public interface TopicMessageContainer
extends MessageContainer

A Topic based MessageContainer

Version:
$Revision: 1.1.1.1 $

Method Summary
 void recoverSubscription(Subscription subscription)
          A durable subscription has started so recovery any messages that are required.
 void setLastAcknowledgedMessageID(Subscription subscription, MessageIdentity messageIdentity)
          Sets the last acknowleged message ID for the given subscriber in this container so that if we shut down and recover we know where to start replaying messages from.
 void storeSubscription(ConsumerInfo info, Subscription subscription)
          Stores the persistence details in the database
 
Methods inherited from interface org.activemq.service.MessageContainer
addMessage, containsMessage, delete, getDestinationName, getMessage, getMessageContainerAdmin, isDeadLetterQueue, registerMessageInterest, unregisterMessageInterest
 
Methods inherited from interface org.activemq.service.Service
start, stop
 

Method Detail

setLastAcknowledgedMessageID

void setLastAcknowledgedMessageID(Subscription subscription,
                                  MessageIdentity messageIdentity)
                                  throws JMSException
Sets the last acknowleged message ID for the given subscriber in this container so that if we shut down and recover we know where to start replaying messages from.

Parameters:
subscription -
messageIdentity -
Throws:
JMSException

recoverSubscription

void recoverSubscription(Subscription subscription)
                         throws JMSException
A durable subscription has started so recovery any messages that are required. This method should find the last acknowledged message for the given subscription and then iterate through any further messages and those that match the subscription should be dispatched to this subscription so that they can be dispatched in the future

Parameters:
subscription -
Throws:
JMSException

storeSubscription

void storeSubscription(ConsumerInfo info,
                       Subscription subscription)
                       throws JMSException
Stores the persistence details in the database

Parameters:
info -
subscription -
Throws:
JMSException


Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.