public class TopicServiceManager extends DestinationServiceManager
Modifier and Type | Field and Description |
---|---|
protected TopicDestinationsResource |
destination |
protected TopicPushStore |
pushStore |
protected List<TopicDeployment> |
topics |
consumerServerLocator, consumerSessionFactory, defaultSettings, jmsOptions, linkStrategy, locator, producerPoolSize, producerTimeToLive, pushStoreFile, registry, sessionFactory, started, timeoutTask
Constructor and Description |
---|
TopicServiceManager(ConnectionFactoryOptions jmsOptions) |
Modifier and Type | Method and Description |
---|---|
void |
deploy(TopicDeployment topicDeployment) |
TopicDestinationsResource |
getDestination() |
TopicPushStore |
getPushStore() |
List<TopicDeployment> |
getTopics() |
void |
setDestination(TopicDestinationsResource destination) |
void |
setPushStore(TopicPushStore pushStore) |
void |
setTopics(List<TopicDeployment> topics) |
void |
start() |
void |
stop() |
getConsumerServerLocator, getConsumerSessionFactory, getDefaultSettings, getJmsOptions, getLinkStrategy, getProducerPoolSize, getProducerTimeToLive, getPushStoreFile, getRegistry, getServerLocator, getSessionFactory, getTimeoutTask, initDefaults, setConsumerServerLocator, setConsumerSessionFactory, setDefaultSettings, setLinkStrategy, setProducerPoolSize, setProducerTimeToLive, setPushStoreFile, setRegistry, setServerLocator, setSessionFactory, setTimeoutTask
protected TopicPushStore pushStore
protected List<TopicDeployment> topics
protected TopicDestinationsResource destination
public TopicServiceManager(ConnectionFactoryOptions jmsOptions)
public TopicPushStore getPushStore()
public void setPushStore(TopicPushStore pushStore)
public List<TopicDeployment> getTopics()
public void setTopics(List<TopicDeployment> topics)
public TopicDestinationsResource getDestination()
public void setDestination(TopicDestinationsResource destination)
public void start() throws Exception
start
in class DestinationServiceManager
Exception
public void deploy(TopicDeployment topicDeployment) throws Exception
Exception
public void stop()
stop
in class DestinationServiceManager
Copyright © 2016 The Apache Software Foundation. All rights reserved.