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: 732259 $
- Author:
- fateev@amazon.com
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
taskRunnerFactory
protected final TaskRunnerFactory taskRunnerFactory
persistenceAdapter
protected final PersistenceAdapter persistenceAdapter
broker
protected RegionBroker broker
DestinationFactoryImpl
public DestinationFactoryImpl(BrokerService brokerService,
TaskRunnerFactory taskRunnerFactory,
PersistenceAdapter persistenceAdapter)
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 © 2005-2011 Apache Software Foundation. All Rights Reserved.