org.apache.activemq.broker.region
Class DestinationFactoryImpl

java.lang.Object
  extended by org.apache.activemq.broker.region.DestinationFactory
      extended by org.apache.activemq.broker.region.DestinationFactoryImpl

public class DestinationFactoryImpl
extends DestinationFactory

Creates standard ActiveMQ implementations of Destination.

Version:
$Revision: 65854 $
Author:
fateev@amazon.com

Field Summary
protected  RegionBroker broker
           
protected  PersistenceAdapter persistenceAdapter
           
protected  TaskRunnerFactory taskRunnerFactory
           
 
Constructor Summary
DestinationFactoryImpl(BrokerService brokerService, TaskRunnerFactory taskRunnerFactory, PersistenceAdapter persistenceAdapter)
           
 
Method Summary
protected  void configureQueue(Queue queue, ActiveMQDestination destination)
           
protected  void configureTopic(Topic topic, ActiveMQDestination destination)
           
 Destination createDestination(ConnectionContext context, ActiveMQDestination destination, DestinationStatistics destinationStatistics)
          Create destination implementation.
 SubscriptionInfo[] getAllDurableSubscriptions(ActiveMQTopic topic)
          Lists all the durable subscirptions for a given destination.
 Set<ActiveMQDestination> getDestinations()
          Returns a set of all the ActiveMQDestination objects that the persistence store is aware exist.
 long getLastMessageBrokerSequenceId()
           
 PersistenceAdapter getPersistenceAdapter()
           
 void removeDestination(Destination dest)
           
 void setRegionBroker(RegionBroker broker)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

taskRunnerFactory

protected final TaskRunnerFactory taskRunnerFactory

persistenceAdapter

protected final PersistenceAdapter persistenceAdapter

broker

protected RegionBroker broker
Constructor Detail

DestinationFactoryImpl

public DestinationFactoryImpl(BrokerService brokerService,
                              TaskRunnerFactory taskRunnerFactory,
                              PersistenceAdapter persistenceAdapter)
Method Detail

setRegionBroker

public void setRegionBroker(RegionBroker broker)
Specified by:
setRegionBroker in class DestinationFactory

getDestinations

public Set<ActiveMQDestination> getDestinations()
Description copied from class: DestinationFactory
Returns a set of all the ActiveMQDestination objects that the persistence store is aware exist.

Specified by:
getDestinations in class DestinationFactory

createDestination

public Destination createDestination(ConnectionContext context,
                                     ActiveMQDestination destination,
                                     DestinationStatistics destinationStatistics)
                              throws Exception
Description copied from class: DestinationFactory
Create destination implementation.

Specified by:
createDestination in class DestinationFactory
Returns:
instance of Queue or Topic
Throws:
Exception

removeDestination

public void removeDestination(Destination dest)
Specified by:
removeDestination in class DestinationFactory

configureQueue

protected void configureQueue(Queue queue,
                              ActiveMQDestination destination)

configureTopic

protected void configureTopic(Topic topic,
                              ActiveMQDestination destination)

getLastMessageBrokerSequenceId

public long getLastMessageBrokerSequenceId()
                                    throws IOException
Specified by:
getLastMessageBrokerSequenceId in class DestinationFactory
Throws:
IOException

getPersistenceAdapter

public PersistenceAdapter getPersistenceAdapter()

getAllDurableSubscriptions

public SubscriptionInfo[] getAllDurableSubscriptions(ActiveMQTopic topic)
                                              throws IOException
Description copied from class: DestinationFactory
Lists all the durable subscirptions for a given destination.

Specified by:
getAllDurableSubscriptions in class DestinationFactory
Throws:
IOException


Copyright © 2009. All Rights Reserved.