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
.
- 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 java.util.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 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
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 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 © 2005-2011. All Rights Reserved.