org.apache.activemq.artemis.rest.queue

Class DestinationServiceManager

java.lang.Object

org.apache.activemq.artemis.rest.queue.DestinationServiceManager

Direct Known Subclasses:

QueueServiceManager, TopicServiceManager

public abstract class DestinationServiceManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.activemq.artemis.api.core.client.ServerLocator	consumerServerLocator
protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory	consumerSessionFactory
protected DestinationSettings	defaultSettings
protected org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions	jmsOptions
protected LinkStrategy	linkStrategy
protected org.apache.activemq.artemis.api.core.client.ServerLocator	locator
protected int	producerPoolSize
protected long	producerTimeToLive
protected String	pushStoreFile
protected BindingRegistry	registry
protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory	sessionFactory
protected boolean	started
protected TimeoutTask	timeoutTask

Constructor Summary

Constructors

Constructor and Description
DestinationServiceManager(org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions)

Method Summary

Modifier and Type	Method and Description
org.apache.activemq.artemis.api.core.client.ServerLocator	getConsumerServerLocator()
org.apache.activemq.artemis.api.core.client.ClientSessionFactory	getConsumerSessionFactory()
DestinationSettings	getDefaultSettings()
org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions	getJmsOptions()
LinkStrategy	getLinkStrategy()
int	getProducerPoolSize()
long	getProducerTimeToLive()
String	getPushStoreFile()
BindingRegistry	getRegistry()
org.apache.activemq.artemis.api.core.client.ServerLocator	getServerLocator()
org.apache.activemq.artemis.api.core.client.ClientSessionFactory	getSessionFactory()
TimeoutTask	getTimeoutTask()
protected void	initDefaults()
void	setConsumerServerLocator(org.apache.activemq.artemis.api.core.client.ServerLocator consumerServerLocator)
void	setConsumerSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory consumerSessionFactory)
void	setDefaultSettings(DestinationSettings defaultSettings)
void	setLinkStrategy(LinkStrategy linkStrategy)
void	setProducerPoolSize(int producerPoolSize)
void	setProducerTimeToLive(long producerTimeToLive)
void	setPushStoreFile(String pushStoreFile)
void	setRegistry(BindingRegistry registry)
void	setServerLocator(org.apache.activemq.artemis.api.core.client.ServerLocator locator)
void	setSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)
void	setTimeoutTask(TimeoutTask timeoutTask)
abstract void	start()
abstract void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

locator

protected org.apache.activemq.artemis.api.core.client.ServerLocator locator

sessionFactory

protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory

consumerServerLocator

protected org.apache.activemq.artemis.api.core.client.ServerLocator consumerServerLocator

consumerSessionFactory

protected org.apache.activemq.artemis.api.core.client.ClientSessionFactory consumerSessionFactory

started

protected boolean started

pushStoreFile

protected String pushStoreFile

defaultSettings

protected DestinationSettings defaultSettings

timeoutTask

protected TimeoutTask timeoutTask

producerPoolSize

protected int producerPoolSize

producerTimeToLive

protected long producerTimeToLive

linkStrategy

protected LinkStrategy linkStrategy

registry

protected BindingRegistry registry

jmsOptions

protected org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions

Constructor Detail

DestinationServiceManager

public DestinationServiceManager(org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions jmsOptions)

Method Detail

getRegistry

public BindingRegistry getRegistry()

setRegistry

public void setRegistry(BindingRegistry registry)

getLinkStrategy

public LinkStrategy getLinkStrategy()

setLinkStrategy

public void setLinkStrategy(LinkStrategy linkStrategy)

getProducerTimeToLive

public long getProducerTimeToLive()

setProducerTimeToLive

public void setProducerTimeToLive(long producerTimeToLive)

getProducerPoolSize

public int getProducerPoolSize()

setProducerPoolSize

public void setProducerPoolSize(int producerPoolSize)

getConsumerSessionFactory

public org.apache.activemq.artemis.api.core.client.ClientSessionFactory getConsumerSessionFactory()

setConsumerSessionFactory

public void setConsumerSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory consumerSessionFactory)

getConsumerServerLocator

public org.apache.activemq.artemis.api.core.client.ServerLocator getConsumerServerLocator()

Returns:

the consumerServerLocator

setConsumerServerLocator

public void setConsumerServerLocator(org.apache.activemq.artemis.api.core.client.ServerLocator consumerServerLocator)

Parameters:

consumerServerLocator - the consumerServerLocator to set

getTimeoutTask

public TimeoutTask getTimeoutTask()

setTimeoutTask

public void setTimeoutTask(TimeoutTask timeoutTask)

getDefaultSettings

public DestinationSettings getDefaultSettings()

setDefaultSettings

public void setDefaultSettings(DestinationSettings defaultSettings)

getServerLocator

public org.apache.activemq.artemis.api.core.client.ServerLocator getServerLocator()

setServerLocator

public void setServerLocator(org.apache.activemq.artemis.api.core.client.ServerLocator locator)

getSessionFactory

public org.apache.activemq.artemis.api.core.client.ClientSessionFactory getSessionFactory()

setSessionFactory

public void setSessionFactory(org.apache.activemq.artemis.api.core.client.ClientSessionFactory sessionFactory)

getPushStoreFile

public String getPushStoreFile()

setPushStoreFile

public void setPushStoreFile(String pushStoreFile)

initDefaults

protected void initDefaults()

start

public abstract void start()
                    throws Exception

Throws:

Exception

stop

public abstract void stop()

getJmsOptions

public org.apache.activemq.artemis.jms.client.ConnectionFactoryOptions getJmsOptions()