public abstract class DestinationServiceManager extends Object
Modifier and Type | Field and Description |
---|---|
protected ServerLocator |
consumerServerLocator |
protected ClientSessionFactory |
consumerSessionFactory |
protected DestinationSettings |
defaultSettings |
protected ConnectionFactoryOptions |
jmsOptions |
protected LinkStrategy |
linkStrategy |
protected ServerLocator |
locator |
protected int |
producerPoolSize |
protected long |
producerTimeToLive |
protected String |
pushStoreFile |
protected BindingRegistry |
registry |
protected ClientSessionFactory |
sessionFactory |
protected boolean |
started |
protected TimeoutTask |
timeoutTask |
Constructor and Description |
---|
DestinationServiceManager(ConnectionFactoryOptions jmsOptions) |
protected ServerLocator locator
protected ClientSessionFactory sessionFactory
protected ServerLocator consumerServerLocator
protected ClientSessionFactory consumerSessionFactory
protected boolean started
protected String pushStoreFile
protected DestinationSettings defaultSettings
protected TimeoutTask timeoutTask
protected int producerPoolSize
protected long producerTimeToLive
protected LinkStrategy linkStrategy
protected BindingRegistry registry
protected ConnectionFactoryOptions jmsOptions
public DestinationServiceManager(ConnectionFactoryOptions jmsOptions)
public BindingRegistry getRegistry()
public void setRegistry(BindingRegistry registry)
public LinkStrategy getLinkStrategy()
public void setLinkStrategy(LinkStrategy linkStrategy)
public long getProducerTimeToLive()
public void setProducerTimeToLive(long producerTimeToLive)
public int getProducerPoolSize()
public void setProducerPoolSize(int producerPoolSize)
public ClientSessionFactory getConsumerSessionFactory()
public void setConsumerSessionFactory(ClientSessionFactory consumerSessionFactory)
public ServerLocator getConsumerServerLocator()
public void setConsumerServerLocator(ServerLocator consumerServerLocator)
consumerServerLocator
- the consumerServerLocator to setpublic TimeoutTask getTimeoutTask()
public void setTimeoutTask(TimeoutTask timeoutTask)
public DestinationSettings getDefaultSettings()
public void setDefaultSettings(DestinationSettings defaultSettings)
public ServerLocator getServerLocator()
public void setServerLocator(ServerLocator locator)
public ClientSessionFactory getSessionFactory()
public void setSessionFactory(ClientSessionFactory sessionFactory)
public String getPushStoreFile()
public void setPushStoreFile(String pushStoreFile)
protected void initDefaults()
public abstract void stop()
public ConnectionFactoryOptions getJmsOptions()
Copyright © 2016 The Apache Software Foundation. All rights reserved.