TopicMessageContainer

Overview

Package

Class

Use

Deprecated

Index

Home >> All >> org >> activemq >> [ service overview ]

PREV CLASS NEXT CLASS

SUMMARY:

JAVADOC |

Sourc code of org.activemq.service.TopicMessageContainer

SOURCE |

Download org.activemq.service.TopicMessageContainer

DOWNLOAD | NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.activemq.service
Interface TopicMessageContainer

All Superinterfaces:: MessageContainer, Service

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(org.activemq.message.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

public void setLastAcknowledgedMessageID(Subscription subscription,
                                         MessageIdentity messageIdentity)
                                  throws javax.jms.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.

recoverSubscription

public void recoverSubscription(Subscription subscription)
                         throws javax.jms.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

storeSubscription

public void storeSubscription(org.activemq.message.ConsumerInfo info,
                              Subscription subscription)
                       throws javax.jms.JMSException

Stores the persistence details in the database