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

Field Summary

Fields

Modifier and Type	Field and Description
protected RegionBroker	broker
protected PersistenceAdapter	persistenceAdapter
protected TaskRunnerFactory	taskRunnerFactory

Constructor Summary

Constructors

Constructor and Description
DestinationFactoryImpl(BrokerService brokerService, TaskRunnerFactory taskRunnerFactory, PersistenceAdapter persistenceAdapter)

Method Summary

Methods

Modifier and Type	Method and Description
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