org.apache.activemq.broker.region
Class DestinationFactory

java.lang.Object
  extended by org.apache.activemq.broker.region.DestinationFactory
Direct Known Subclasses:
DestinationFactoryImpl

public abstract class DestinationFactory
extends Object

Used to create Destinations. One instance of DestinationFactory is used per BrokerService.

Author:
fateev@amazon.com

Constructor Summary
DestinationFactory()
           
 
Method Summary
abstract  Destination createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)
          Create destination implementation.
abstract  SubscriptionInfo[] getAllDurableSubscriptions(ActiveMQTopic topic)
          Lists all the durable subscirptions for a given destination.
abstract  Set<ActiveMQDestination> getDestinations()
          Returns a set of all the ActiveMQDestination objects that the persistence store is aware exist.
abstract  long getLastMessageBrokerSequenceId()
           
abstract  void removeDestination(Destination dest)
           
abstract  void setRegionBroker(RegionBroker regionBroker)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DestinationFactory

public DestinationFactory()
Method Detail

createDestination

public abstract Destination createDestination(ConnectionContext context,
                                              ActiveMQDestination destination,
                                              DestinationStatistics destinationStatistics)
                                       throws Exception
Create destination implementation.

Throws:
Exception

removeDestination

public abstract void removeDestination(Destination dest)

getDestinations

public abstract Set<ActiveMQDestination> getDestinations()
Returns a set of all the ActiveMQDestination objects that the persistence store is aware exist.


getAllDurableSubscriptions

public abstract SubscriptionInfo[] getAllDurableSubscriptions(ActiveMQTopic topic)
                                                       throws IOException
Lists all the durable subscirptions for a given destination.

Throws:
IOException

getLastMessageBrokerSequenceId

public abstract long getLastMessageBrokerSequenceId()
                                             throws IOException
Throws:
IOException

setRegionBroker

public abstract void setRegionBroker(RegionBroker regionBroker)


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.