org.apache.activemq.broker.region
Class DestinationFactoryImpl
java.lang.Object
org.apache.activemq.broker.region.DestinationFactory
org.apache.activemq.broker.region.DestinationFactoryImpl
public class DestinationFactoryImpl
- extends DestinationFactory
Creates standard ActiveMQ implementations of Destination
.
- Version:
- $Revision: 474986 $
- Author:
- fateev@amazon.com
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
memoryManager
protected final UsageManager memoryManager
taskRunnerFactory
protected final TaskRunnerFactory taskRunnerFactory
persistenceAdapter
protected final PersistenceAdapter persistenceAdapter
broker
protected RegionBroker broker
DestinationFactoryImpl
public DestinationFactoryImpl(UsageManager memoryManager,
TaskRunnerFactory taskRunnerFactory,
PersistenceAdapter persistenceAdapter)
setRegionBroker
public void setRegionBroker(RegionBroker broker)
- Specified by:
setRegionBroker
in class DestinationFactory
getDestinations
public java.util.Set 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 java.lang.Exception
- Description copied from class:
DestinationFactory
- Create destination implementation.
- Specified by:
createDestination
in class DestinationFactory
- Returns:
- instance of
Queue
or Topic
- Throws:
java.lang.Exception
configureQueue
protected void configureQueue(Queue queue,
ActiveMQDestination destination)
configureTopic
protected void configureTopic(Topic topic,
ActiveMQDestination destination)
getLastMessageBrokerSequenceId
public long getLastMessageBrokerSequenceId()
throws java.io.IOException
- Specified by:
getLastMessageBrokerSequenceId
in class DestinationFactory
- Throws:
java.io.IOException
getPersistenceAdapter
public PersistenceAdapter getPersistenceAdapter()
getAllDurableSubscriptions
public SubscriptionInfo[] getAllDurableSubscriptions(ActiveMQTopic topic)
throws java.io.IOException
- Description copied from class:
DestinationFactory
- Lists all the durable subscirptions for a given destination.
- Specified by:
getAllDurableSubscriptions
in class DestinationFactory
- Throws:
java.io.IOException
Copyright © 2009 Apache Software Foundation. All Rights Reserved.